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

Jacky 发表于: 2019-11-13   最后更新时间: 2019-11-13  

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"


您需要解锁本帖隐藏内容请: 点击这里
本帖隐藏的内容




上一条: 如何实时监控kafka队列是否有新数据
下一条: kafka集群主备同步以及流量切换

  • bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group
    
    bin/kafka-consumer-groups.sh --bootstrap-server server:9092 --describe --all-groups