congbo

issue: reproduce: 1. redeliver one consumer received message of a batch message, will remove this message from this consumer pending acks 2. if this message is removed and doesn't redeliver...

issue: reduce the consumer `unackedCount` use incorrect consumer. reproduce step ``` for (int i = 0; i < 5; i++) { producer.newMessage().value(("Hello Pulsar - " + i).getBytes()).sendAsync(); } // consume-1...

[improve][txn] Add getState in transaction for client API

4

### Motivation now `org.apache.pulsar.client.api.transaction.Transaction` dont have a interface for user to get the transaction state. user can get the transaction state to do user's own op. ### Modifications 1. add...

[fix][test] fix testEndTxnWhenCommittingOrAborting flaky test

1

issue: https://github.com/apache/pulsar/actions/runs/3383985489/jobs/5620564078 ### Motivation Transaction op count update after the write response, so we need to wait for the change to succeed https://github.com/congbobo184/pulsar/blob/2b441bd2ab4b71d5bc182f85c62fbea633c4ce4b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarCommandSenderImpl.java#L314-L317 https://github.com/congbobo184/pulsar/blob/2b441bd2ab4b71d5bc182f85c62fbea633c4ce4b/pulsar-broker/src/main/java/org/apache/pulsar/broker/service/PulsarCommandSenderImpl.java#L334-L337 ### Modifications wait count changed ###...

[improve][client] PIP-218: Consumer batchReceive() single partition every receive

1

### Motivation https://github.com/apache/pulsar/issues/18182 ### Modifications [](https://github.com/apache/pulsar/issues/18182) ### Verifying this change add test for batchReceive single topic messages add test for batchReceive multi-topic messages ### Does this pull request potentially affect...

PIP-218: Consumer batchReceive() single partition every receive

2

### Motivation Currently, client API does not use `acknowledgeCumulative` simple and easy to understand. If the user uses the receive() interface to consume multi-partition topic, there are two ways to...

### Search before asking - [X] I searched in the [issues](https://github.com/apache/pulsar-client-cpp/issues) and found nothing similar. ### Version pulsar: apachepulsar/pulsar:2.11.0 os : mac 12.6 cpp client version : main branch ###...

[fix][cursor] Fix enable maxPosition cursor will read in deap loop

6

### Motivation Now we don't check `OpAddEntry` can read entry is smaller than maxReadPosition, if readPosition is bigger than maxReadPosition, we only can read an empty list as result. In...

[client] new API to check if Bookkeeper client is connected to metadata service

1

# Motivation when zookeeper disconnect, use bookkeeper api to create new ledger will fail. add a new api to check metadata driver is available, if not available, use current ledger...