Fork me on GitHub

kafka-run-class.sh kafka.tools.ConsumerOffsetChecker --broker-info --group $group --topic $topic --zookeeper $zk_host:2181

0.9.0以后官方建议使用

kafka-consumer-groups.sh --new-consumer --bootstrap-server $broker:9092 --describe --group $topic

发表评论

电子邮件地址不会被公开。

此站点使用Akismet来减少垃圾评论。了解我们如何处理您的评论数据