kafka-simple-consumer-shell.sh脚本不存在了,如何解析__consumer_offsets日志

Jacky 发表于: 2019-11-13   最后更新时间: 2021-10-13 17:29:17   2,497 游览

kafka_2.12-2.2.1版本里没有kafka-simple-consumer-shell.sh脚本了,那后续的版本里是哪个脚本代替呢?

之前的版本是可能通过命令查看消费组的消费进度。

kafka-console-consumer.sh --topic __consumer_offsets --partition 33 --broker-list IP:PORT --formatter "kafka.coordinator.group.GroupMetadataManager\$OffsetsMessageFormatter"
发表于 2019-11-13
添加评论
bin/kafka-consumer-groups.sh --bootstrap-server server:9092 --describe --all-groups
bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group
Jacky -> 雪花 4年前

谢谢,这个查看到的跟解析默认topic的日志看到的还是有区别。

你的答案

查看kafka相关的其他问题或提一个您自己的问题