Zike Yang

Fixes #17014 ### Motivation The root cause of #17014 is a race condition in the `batchMessageContainer` when discarding the messages and releasing the semaphore. We need to release semaphore first...

Fixes #16804 ### Motivation The property "pulsar.allocator.leak_detection" has wrong description: "Service URL provider for Pulsar service" in https://pulsar.apache.org/docs/client-libraries-java/#client-memory-allocator-configuration. In addition, this PR also remove 'Client memory allocator configuration' section from...

### Motivation Currently, Java tests consume major CI resources. And it is not necessary to run all the tests for changes that are only on the C++ or python parts...

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation Currently, we doesn't specify the version for every dependency in the cpp client:...

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Example failure https://github.com/apache/pulsar/runs/7720536583?check_suite_focus=true#step:10:1299 ### Exception stacktrace ``` java.lang.AssertionError: expected [10] but found [9] at...

Fixes #16761 ### Motivation When C++ client calls `ConsumerImpl::getLastMessageIdAsync`, if the connection is not established, the callback will complete with `ResultNotConnected`. ### Modifications * Wait until the connection is established...

Flaky-test: ManagedCursorMetricsTest. testManagedCursorMetrics

2

ManagedCursorMetricsTest. testManagedCursorMetrics is flaky. It fails sporadically. https://github.com/apache/pulsar/pull/16878 didn't fix the issue. The problem still exists in the latest code. [example failure](https://github.com/apache/pulsar/runs/7666921482?check_suite_focus=true#step:10:950) ``` Error: testCursorReadWriteMetrics(org.apache.pulsar.broker.stats.ManagedCursorMetricsTest) Time elapsed: 0.449 s

Support transaction

1

Currently, the pulsar go client doesn't support transaction. We could add support for it. **Additional context** The PIP for the transaction feature: https://github.com/apache/pulsar/wiki/PIP-31%3A-Transaction-Support

How to use Logical types in Avro schema?

2

I want to use the logical types in the Avro schema. But seems that Avro C# doesn't support logical types. It will throw the exception like below: ``` Avro.AvroException: Unknown...

[WIP] Multi-topics consumer and partitioned consumer support

4

This PR adds support for the multi-topics consumer and partitioned consumer. Co-authored-by: Zike Yang Co-authored-by: Zixuan Liu