Gleiphir2769 opened a new pull request, #903:
URL: https://github.com/apache/pulsar-client-go/pull/903
Master Issue: #183
### Motivation
Cumulative confirmation is a useful feature. Users can use this feature to
ack messages in the stream up to (and including) provided message.
Issue #183 shows more details.
### Modifications
- Add interface `CumulativeAck` and `CumulativeAckID` for `Consumer`.
``` golang
// CumulativeAck the reception of all the messages in the stream up to (and
including)
// the provided message.
CumulativeAck(msg Message) error
// CumulativeAckID the reception of all the messages in the stream up to
(and including)
// the provided message, identified by its MessageID
CumulativeAckID(msgID MessageID) error
```
- Add the `CumulativeAck` and `CumulativeAckID` implementation for
`consumer`, `multiTopicConsumer`, `regexConsumer` and `mockConsumer`.
- Add the unit test for cumulative ack in `consumer_test.go`. (not finished)
### Verifying this change
- [x] Make sure that the change passes the CI checks.
### Does this pull request potentially affect one of the following parts:
*If `yes` was chosen, please highlight the changes*
- The public API: yes
--
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]
