kafka 1.1.0重置消费进度
2018-10-22 本文已影响0人
ssssssnake
-
查看当前消费进度（需要消费者在线）
./kafka-consumer-groups.sh --bootstrap-server fz22:9092 --group RecordStoreGroupID --describe
image.png
-
重置消费进度（需要消费者离线）
./kafka-consumer-groups.sh --bootstrap-server fz22:9092 --group RecordStoreGroupID --reset-offsets --to-earliest --topic RecordStoreTopic --execute
image.png
-
查看Topic的offset，确认修改后的消费进度是否正确
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list fz22:9092 -topic RecordStoreTopic --time -2
image.png
