August 2025 07:51
To: [email protected]
Cc: [email protected]
Subject: Re: Kafka 4.1 Queue Semantics missing APIs
3. Acknowledge the records based on some ID like offset
shareConsumer.acknowledge(record.offset(), ACCEPT);
Regards,
Shekhar Prasad Rajak,
Contact : +918142478937Blog | Github |
3. Acknowledge the records based on some ID like offset
shareConsumer.acknowledge(record.offset(), ACCEPT);
Regards,
Shekhar Prasad Rajak,
Contact : +918142478937Blog | Github | Twitter
On Friday 29 August 2025 at 11:37:24 am GMT+5:30, RShekhar Prasad
wrote:
Hello team,
While explo
Hello team,
While exploring Kafka Queue semantics, we released there is some APIs that is
useful but missing for example :
1. Multiple polls and ack later batch wise in explicit mode :
ConsumerRecords batch1 = shareConsumer.poll(Duration.ofMillis(100));
ConsumerRecords batch2 = shareConsumer.
