Reset Kafka offsets

Published by admin on

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

Leave a Reply

Your email address will not be published. Required fields are marked *