One of the most important features from Apache Kafka is how it manages
Multiple Consumers. Each
consumer group has a current
determine at what point in a
consumer group has consume
messages. So, each
consumer group can manage its
This offers the possibility to rollback in time and reprocess messages from
the beginning of a
topic and regenerate the current status of the system.
But how to do it (programmatically)?