kafka 1.1.0重置消费进度

查看当前消费进度（需要消费者在线）
./kafka-consumer-groups.sh --bootstrap-server fz22:9092 --group RecordStoreGroupID --describe

重置消费进度（需要消费者离线）
./kafka-consumer-groups.sh --bootstrap-server fz22:9092 --group RecordStoreGroupID --reset-offsets --to-earliest --topic RecordStoreTopic --execute

查看Topic的offset，确认修改后的消费进度是否正确
./kafka-run-class.sh kafka.tools.GetOffsetShell --broker-list fz22:9092 -topic RecordStoreTopic --time -2