Commit Message Individually or Batch wise

57 views
Skip to first unread message

Akhil Job

unread,
Nov 25, 2020, 4:27:30 AM11/25/20
to kafka-clients
Hi all , I was trying to make kafka consumer which would collect messages for a particular amount of time after that I could manually commit with the messages that has been collected. But I could nt find a method or api from sarama that could be used to commit a message or a barch of message , Please help out 

Andreas Sittler

unread,
Nov 25, 2020, 4:48:50 AM11/25/20
to kafka-clients

[1]
Disable auto-commit
[2]
Use one of the commit-methods here
https://docs.confluent.io/platform/current/clients/javadocs/org/apache/kafka/clients/consumer/KafkaConsumer.html


On 25/11/2020 10:27, Akhil Job wrote:
Hi all , I was trying to make kafka consumer which would collect messages for a particular amount of time after that I could manually commit with the messages that has been collected. But I could nt find a method or api from sarama that could be used to commit a message or a barch of message , Please help out  --
You received this message because you are subscribed to the Google Groups "kafka-clients" group.
To unsubscribe from this group and stop receiving emails from it, send an email to kafka-client...@googlegroups.com.
To view this discussion on the web visit https://groups.google.com/d/msgid/kafka-clients/056b4b7b-9c97-4e8d-b6f6-1027dce574a0n%40googlegroups.com.

Reply all
Reply to author
Forward
0 new messages