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,326 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 28 pull requests in 4 repositories
apache/pulsar 21 pull requests
- [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
- Add the Maven wrapper
- [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
- PIP-45: Revalidate leader election after session is recovered
- [broker] Adding logging to JavaInstanceRunnable to help debug issues like #10460
- Fix the possible memory leak of TopicPolicies
- [Issue #10427] Add AvroSchema UUID support fix
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: > I tested pulsar 2.7.1 docker on my local machine. Also java client version is 2.7.1
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 29 other issues in 3 repositories
streamnative/pulsar
20
open
3
closed
- ISSUE-10537: flaky test LoadBalancerTest often failed
- ISSUE-10526: Pulsar adds the function of querying topic messages
- ISSUE-10523: Key_Shared subscription is not evenly distributed
- ISSUE-10522: TransactionEndToEndTest was broken by recent merged
- ISSUE-10519: Develop for Java Client Plusar Statistics
- ISSUE-10517: pulsar functions command: topics-pattern option does not work as intended?
- ISSUE-10515: HasMessageAvailable incorrectly returns "true" when there are no available messages
- ISSUE-10514: pulsar-io-hdfs connect hdfs error
- ISSUE-10510: Node js pulsar-client
- ISSUE-10509: Pulsar IO Sink errors aren't bubbled up properly for Async Functions
- ISSUE-10505: [Functions] Context.getPulsarAdmin() may allow access to data from other tenants
- ISSUE-10503: [functions worker] allow custom configs to plugin worker service
- ISSUE-10497: missing message on partitioned topics with delayed messages
- ISSUE-10496: Latest Spark Connectors for Pulsar
- ISSUE-10495: msgDropRate metric is not available through non-deprecated Java interface, CLI, or Pulsar Manager
- ISSUE-10488: Add ability to seek from current position in Reader interface
- ISSUE-10483: Reader does not return any message when configured with reading inclusive latest messageId
-
ISSUE-10481: org.apache.bookkeeper.mledger.offload.jcloud.provider.JCloudBlobStoreProvider caches aws credentials unnecessarily causing
InvalidTokenerror when running on EC2 instance for more than 24 hours - ISSUE-10479: Allow Java client to create consumer with receiverQueueSize(0) when receiving with timeout
- ISSUE-10473: PulsarStandaloneBuilder: make it a public API
- ISSUE-10472: GenericJsonRecord throws NPE
- ISSUE-10464: Shared subscription with Earliest initial position doesn't clear backlog
- ISSUE-10462: [Functions] Updating function wipes out userConfig