我想检查手动分配给特定主题的消费者组的延迟,这可能吗。我使用的是kafka-0.10.0.1。我使用了sh kafka-run-class.sh kafka.admin.consumergroupcommand-new consumer-description-bootstrap serverlocalhost:9092 -组测试,但它说没有组存在,所以我想知道当我们手动分配一个分区,我们可以检查消费者的滞后。
我想检查手动分配给特定主题的消费者组的延迟,这可能吗。我使用的是kafka-0.10.0.1。我使用了sh kafka-run-class.sh kafka.admin.consumergroupcommand-new consumer-description-bootstrap serverlocalhost:9092 -组测试,但它说没有组存在,所以我想知道当我们手动分配一个分区,我们可以检查消费者的滞后。
1条答案
按热度按时间qv7cva1a1#
./kafka-consumer-groups.sh—引导服务器localhost:9092 --describe --组
.
如果您需要api支持或可视延迟监视,可以使用https://github.com/yahoo/kafka-manager