pulsar-client-go
pulsar-client-go copied to clipboard
Support batch index level Ack
Is your feature request related to a problem? Please describe. No
Describe the solution you'd like
When receiving the batched messages, Golang consumer can build a intermediate ack_tracker that keeps updating ack_set and sweeps when ack_set becomes all 1s, before sending the ack out.