Posts

Showing posts with the label offset

Kafka Commit Offset Manually

Image
Kafka Commit Offset Manually . So, in fact, if you want to cleanly manually commit a kafka message from a talend route, you can : Following examples shows how to commit offset asynchronously with a callback. Kafka Connect Offset commit errors (II) El Javi from www.javierholguera.com Manually committing offsets in kafka. Manually assigned partitions¶ when using the assign api you are responsible for keeping track of consumers. I need kafka expert advise to suggest the best approach.