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"