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"
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
谢谢,这个查看到的跟解析默认topic的日志看到的还是有区别。
你的答案