016. CLI. Resetting Offsets. - MarkHuntDev/my-kafka-exercises GitHub Wiki
-
Reset offsets to earliest
- $ kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group <group_name> --reset-offsets --to-earliest --execute --topic <topic_name>
-
Shift offsets
- $ kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group <group_name> --reset-offsets --shift-by <positive_or_negative_number> --execute --topic <topic_name>