BewareMyPower opened a new pull request, #175:
URL: https://github.com/apache/pulsar-client-cpp/pull/175

   ### Motivation
   
   Currently the main branch is broken by the concurrent merge of 
https://github.com/apache/pulsar-client-cpp/pull/153 and 
https://github.com/apache/pulsar-client-cpp/pull/151. It's because when a 
batched message id is constructed from deserialization, there is no `getBitSet` 
implementation of the internal acker.
   
   ### Modifications
   
   Add a `bool` parameter to `MessageIdImpl::getBitSet` to indicate whether the 
message ID is batched. The logic is similar with
   
   
https://github.com/apache/pulsar/blob/299bd70fdfa023768e94a8ee4347d39337b6cbd4/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PersistentAcknowledgmentsGroupingTracker.java#L325-L327
   
   and
   
   
https://github.com/apache/pulsar/blob/299bd70fdfa023768e94a8ee4347d39337b6cbd4/pulsar-client/src/main/java/org/apache/pulsar/client/impl/PersistentAcknowledgmentsGroupingTracker.java#L345-L347
   
   Add a `testMessageIdFromBuild` to test the acknowledgment for a message ID 
without an acker could succeed for a consumer that enables batch index ACK.
   
   ### TODO
   
   In future, https://github.com/apache/pulsar/pull/19031 might be migrated 
into the C++ client to fix the consumer that disables batch index ACK.
   
   ### Documentation
   
   <!-- DO NOT REMOVE THIS SECTION. CHECK THE PROPER BOX ONLY. -->
   
   - [ ] `doc-required` 
   (Your PR needs to update docs and you will update later)
   
   - [x] `doc-not-needed` 
   (Please explain why)
   
   - [ ] `doc` 
   (Your PR contains doc changes)
   
   - [ ] `doc-complete`
   (Docs have been already added)
   


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]

Reply via email to