loading...
When kafka consumers are subscribing to a topic, as and when messages are produced, they are consumed by the consumers. But due to high traffic or latency or high load issues, there would be a lag in consuming the messages. With Kafka binaries it is possible to know the lag of every consumer group, and
Status of offsets of consumer groups are stored on Kafka broker. If that should be reset, for ex based on a duration ./bin/kafka-consumer-groups --bootstrap-server kafkaserver:9092 --group consumergroupname --reset-offsets --by-duration 1522760000 --execute If that should be reset, for ex based on a timestamp ./bin/kafka-consumer-groups --bootstrap-server kafkaserver:9092 --group consumergroupname --reset-offsets --to-datetime 2019-08-28T19:45:00.000 --execute