Create your own GitHub profile
Sign up for your own profile on GitHub, the best place to host code, manage projects, and build software alongside 50 million developers.
Sign up
Pinned
849 contributions in the last year
Activity overview
Contributed to
apache/pulsar,
apache/pulsar-client-go,
openmessaging/openmessaging-benchmark
and 5 other
repositories
Contribution activity
July 2020
Created a pull request in apache/pulsar that received 7 comments
Improved in max-pending-bytes mechanism for broker
Motivation There are few issues with the current implementation of the broker-wide throttling based on max-outstanding bytes in broker that was add…
+176
−182
•
7
comments
- Avoid pulsar-client-api dependency on txn-common
- Fixed deadlock between create function and leader initialization
- The test should wait until the worker leader is ready, otherwise the request to create function will fail
- Get last entry is trying to read entry -1
- Fixed flaky test and resource leak in JavaInstanceTest
- Use CGroup CPU usage when present
- Fix: Exception being ignored in PulsarAdmin
- [ISSUE #6116] fix the download links for and the sequence of source and sink
- [pulsar-broker] Cleanup already deleted namespace topics
- [Issue 7502] Fixed some compilation issues when enabling -Wall.
- [pulsar-test] shutdown pulsar-client to cleanup forcefully
- Decompression payload if needed in KeyShared subscription
- [C++] Add unit tests for key shared consumer
- make AsyncHttpConnector.delayer thread daemon
- Log scheduler stats for Pulsar Functions
- [Issue 5736] Add test checks in branches
- Add readCompact option
- Handle NotAllowed Exception at the client side.
- fix update partitions error for non-persistent topic
- Fix batch ackset recycled multiple times.
- [broker] Consumer is registered on dispatcher even if hash range conflicts on Key_Shared subscription
- [Issue 7402] Fix GCS offload operation error
- Implement rebalance mechanism in Pulsar Functions
- [Issue 7347] Avoid the NPE occurs in method `ManagedLedgerImpl.isOffloadedNeedsDelete`