In 0.10 it seems we can reset the offset to a specific position with seek()
Short of writing code is there a command line util for this? It doesn't seem so, so far?
Use the kafka-consumer-groups.sh to change or reset the offset. You would have to specify the topic, consumer group and use the –reset-offsets flag to change the offset.
You can delete consumer groups from Kafka instances by using the Kafka command line tool of your Kafka client. NOTE: Ensure that the client uses the same version as the Kafka instance. [root@zk-server-1 bin]# ./kafka-consumer-groups.sh --bootstrap-server 172.31.
I've just implemented a simple command line tool for this purpose - https://github.com/serejja/kafka-offset-mgr.
Feel free to try it out and post issues/PRs if necessary.
If you love us? You can donate to us via Paypal or buy me a coffee so we can maintain and grow! Thank you!
Donate Us With