To set this up scenario set ‘enable.auto.commit’ to true and set ‘auto.commit.interval.ms’ to a higher number and committing offsets by a call to cons

At-most-once is the default behavior of KAFKA, Depending on how consumer is configured for auto offset management, in some cases this message pattern

Reads an avro message.

Create and publish an avro type message.

Support class for avro messages.

To achieve exactly once scenario, offset should be manually managed (DO-NOT do auto offset management). <p/> The consumer can register with the Kafka

To achieve exactly once scenario, offset should be manually managed (DO-NOT do auto offset management). <p/> The consumer can register with the Kafka

Re-balancer for any subscription changes.

The partition offset are stored in an external storage. In this case in a file system. <p/>

A sample client to produce a bunch of messages.