How to reset Offsets


I am using cp-kafka:3.2.0 in docker, I need to reset offsets for all my group-id created in kafka. I am using below coomand but It’s not working

kafka-consumer-groups --bootstrap-server localhost:9092 --group logstash --reset-offsets --shift-by -2 --execute --topic topic-logstash
Exception in thread “main” joptsimple.UnrecognizedOptionException: reset-offsets is not a recognized option
at joptsimple.OptionException.unrecognizedOption(
at joptsimple.OptionParser.handleLongOptionToken(
at joptsimple.OptionParserState$2.handleArgument(
at joptsimple.OptionParser.parse(
at kafka.admin.ConsumerGroupCommand$ConsumerGroupCommandOptions.(ConsumerGroupCommand.scala:531)
at kafka.admin.ConsumerGroupCommand$.main(ConsumerGroupCommand.scala:47)
at kafka.admin.ConsumerGroupCommand.main(ConsumerGroupCommand.scala)

Please someone guide me,

I’d suggest using a latest version of Kafka container, but make sure you use correct hyphens and no spaces in your arguments. Run kafka-consumer-groups on its own, and look at the supported arguments. Also do dry run rather than immediately execute.

Your command looks correct, otherwise.

Note: In an effort to make the forum more organized, your error is unrelated to Kafka Connect.

This topic was automatically closed 30 days after the last reply. New replies are no longer allowed.