1. 列举消费者
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --list
2. 查看偏移量
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group consumer --describe
3. 移动至最新
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --group multi-alarms-pro --topic Alarms --reset-offsets --to-latest -execute
本文转载自: https://blog.csdn.net/bland107/article/details/140705207
版权归原作者 穆琪muqi 所有， 如有侵权，请联系我们删除。
版权归原作者 穆琪muqi 所有， 如有侵权，请联系我们删除。