sijie
Follow
Popular repositories
-
-
-
-
-
Forked from sksamuel/pulsar4s
Idiomatic, typesafe, and reactive Scala client for Apache Pulsar
-
Forked from streamnative/awesome-pulsar
A curated list of Pulsar tools, integrations and resources.
3,306 contributions in the last year
Less
More
Contribution activity
May 2021
Created 3 commits in 2 repositories
Created a pull request in streamnative/function-mesh-website that received 6 comments
Opened 2 other pull requests in 2 repositories
streamnative/charts
1
merged
streamnative/function-mesh-website
1
merged
Reviewed 35 pull requests in 4 repositories
apache/pulsar 28 pull requests
- PIP-45: Migrate NamespaceService to use MetadataStore
- get function cluster from broker config when start function worker with broker
-
[fix #9640] remove
pulsar-client-admin-apidependency :pulsar-client-original - Add the Maven wrapper
- Fixed missed ZK caching when fetching list of namespaces for a tenant
- [Schema] Add schemaType field in SchemaHash
- [Transaction] Fix transaction end op retry problem.
- [Issue 10546] fix sink/source exception stats
- [Issue #10427] Add AvroSchema UUID support fix
- [Issue 5720][authz] - add topics authz granularity
- [Branch-2.7] Fix deadlock on Monitoring thread blocked by LeaderService.isLeader()
- [Issue 10242] add authentication data for remote cluster
- Move out the key_shared related tests from the quarantine group.
- [#10503] allow user to set custom configs to plugin worker service
-
[fix #10235] fix deadlock on Monitoring thread blocked by
LeaderService.isLeader() - [Issue 10445][pulsar-io] Exposed SubscriptionType in the SinkContext
- [CLIENT] fixed NPE in GenericJsonRecord
- Support Pulsar Auth token for Debezium and Kafka connect adaptor
- [Issue 10300][broker] Fix authorization error if partition number of partitioned topic is updated.
- Reader support seek from separate messageId/time
- Make Consumer thread safe and lock-free
- Fix hasMessageAvailable return true but can't read message
- Fixes function api can not use authdata to check superuser
- [pulsar-broker] Handle NPE in unblock stuck subscrption task when dis…
- Improve error handling during localrun start
- Some pull request reviews not shown.
streamnative/charts 3 pull requests
streamnative/function-mesh-website 3 pull requests
apache/bookkeeper 1 pull request
Created an issue in streamnative/pulsar that received 1 comment
ISSUE-10524: Messages aren't evenly distributed for multiple Key_Shared consumers
Original Issue: apache#10524
I tested pulsar 2.7.1 docker on my local machine. Also java client version is 2.7.1
1 producer with 4 consumer in a …
1
comment
Opened 53 other issues in 4 repositories
streamnative/pulsar
35
open
11
closed
- ISSUE-10606: Is there any incompatibility when upgrading from 2.4 to 2.7 in cluster mode?
- ISSUE-10603: Cannot produce message to those topics without setting topic policies, when enable preciseTopicPublishRateLimiterEnable
- ISSUE-10602: [Tests] Broker startup sporadically deadlocks when ZK client thread gets blocked in SimpleLoadManagerImpl.updateRanking
- ISSUE-10596: Python client: broken/missing Avro schema support
- ISSUE-10589: Tests that don't belong to any TestNG group aren't run at all in pulsar-broker module
- ISSUE-10588: When to support the springboot ecosystem
- ISSUE-10587: Support alias for the Schema and Message
- ISSUE-10584: broker.conf documentation : wrong tokenSecretKey base64 inline description
- ISSUE-10582: Unable to build RPM packages
-
ISSUE-10579: Sinks API endpoint
getSinkInfodoes not properly return a list of topic inputs - ISSUE-10578: Relative paths do not work for pulsar-admin schema upload --filename flag
- ISSUE-10577: CLI tools should have a command for showing the currently running/installed version.
- ISSUE-10575: Pulsar c++ subscriber receiving messages retroactively
- ISSUE-10569: Flaky-test: BacklogQuotaManagerTest.testTriggerBacklogQuotaSizeWithReader
- ISSUE-10571: When I want to get the parameter returned by the consumer after sending the message, there is no way to get it.
- ISSUE-10570: Flaky-test: BacklogQuotaManagerTest.testConsumerBacklogEvictionWithAckTimeQuota
- ISSUE-6054: Catastrophic frequent random subscription freezes, especially on high-traffic topics.
- ISSUE-10562: Using Windows docker integration test to display the error of win32.kernel
- ISSUE-10560: [Go Functions] support state storage API
- ISSUE-10558: Pulsar manager successfully added the administrator account with password "admin", but the web login password can not be less than 6 digits.
- ISSUE-10555: Flaky-test: SimpleProducerConsumerTest.testActiveAndInActiveConsumerEntryCacheBehavior
- ISSUE-10547: Cannot publish OSX artifacts for 2.7.2
- ISSUE-10546: Sink status reports incorrect number of Exceptions
- ISSUE-10537: flaky test LoadBalancerTest often failed
- ISSUE-10526: Pulsar adds the function of querying topic messages
- Some issues not shown.