Baodi Shi

Reduce the installing nodes time

2

At present, when using openchaos, if you want to install dledger, you will pull the source code for each node and rebuild it, which takes a long time, and sometimes...

Flaky-test: PersistentStreamingDispatcherBlockConsumerTest.testBrokerSubscriptionRecovery

1

### 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/7739485769?check_suite_focus=true ### Exception stacktrace ``` Error: Tests run: 13, Failures: 1, Errors:...

[refactor][client c++] Delete PartitionedConsumerImpl, use MultiTopicsConsumerImpl instead

3

### Motivation The code of the C++ client is still relatively old, after #1365, the java client used `MultiTopicConsumerImpl` instead of `PartitionedConsumerImpl`. ### Modifications - Delete PartitionedConsumerImpl, use MultiTopicsConsumerImpl instead....

Flaky-test: TxnLogBufferedWriterTest.testFlushThresholds

1

TxnLogBufferedWriterTest.testFlushThresholds is flaky. It fails sporadically. [example failure](https://github.com/apache/pulsar/runs/7428130703?check_suite_focus=true) ``` Error: Tests run: 6, Failures: 2, Errors: 0, Skipped: 4, Time elapsed: 7.931 s

[improve][client c++] Support KeyValue Schema.

11

### Motivation C++ client Support KeyValue Schema. For key and value schema, just only support `AVRO` and `JSON` type(consistent with java client). ### Modifications - A new constructor is added...

[feat][cpp] Consumer support batch receive messages.

2

### Motivation https://github.com/apache/pulsar/issues/17140 ### Modifications - Consumer support batch receives messages. - Abstract common implementation to `ConsumerImplBase`. - `acknowledge(Messages messages)` is not supported for the time being, and it needs...

[improve][cpp] Support acknowledging a list of messages

2

### Motivation https://github.com/apache/pulsar/issues/17428 ### Modifications - Add acknowledge message id list API. ### Documentation - [ ] `doc-required` (Your PR needs to update docs and you will update later) -...

[fix][client] Messages with inconsistent consumer epochs are not filtered when using batch receive and trigger timeout.

12

### Motivation Messages with inconsistent consumer epochs are not filtered when using batch receive and trigger timeout. ### Modifications - Add consumer epoch on `notifyPendingBatchReceivedCallBack`. - Reuse `notifyPendingBatchReceivedCallBack` logic. ###...

[feature request] C++ and Python support ack timeout redelivery backoff

1

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar/issues) and found nothing similar. ### Motivation [PIP 130: Apply redelivery backoff policy for ack timeout](https://github.com/apache/pulsar/issues/13528) ### Solution Refer java...

[fix][cpp] Use weak ptr avoid circular references.

1

### Motivation Capturing shared ptr in the timer function will cause a circular reference. ### Modifications - Use weak ptr instead shared ptr. ### Documentation - [x] `doc-not-needed`