Reply
Contributor
Posts: 76
Registered: ‎10-04-2017

Kafka bootstrap consumer offset reset

[ Edited ]

Hi,

 

We are using kafka 0.10.2 with CDH5.11. Our users use both zookeeper and bootstrap consumer groups. Is it possible to reset the offset of bootstrap consumers?

Cloudera Employee
Posts: 221
Registered: ‎01-09-2014

Re: Kafka bootstrap consumer offset reset

The easiest way to reset the offsets is to just change the consumer group.id. Kafka will detect there are no pre-existing offsets, and then use the auto.offset.reset value to determine whether to reset to earliest or latest.

If you are using CDK3.0 (0.11 upstream), you can use the --reset-offsets option to kafka-consumer-groups:
https://cwiki.apache.org/confluence/display/KAFKA/KIP-122%3A+Add+Reset+Consumer+Group+Offsets+toolin...

-pd
Announcements