返回到文章

采纳

编辑于

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

kafka

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"