我想检查手动分配给特定主题的消费者群体的滞后,这可能吗? . 我正在使用Kafka - 0.10.0.1 . 我使用了sh kafka-run-class.sh kafka.admin.ConsumerGroupCommand -new-consumer -describe -bootstrap-server localhost:9092 -group test但它说没有组存在,所以我想知道当我们手动分配分区时,我们可以检查消费者的滞后 .
./kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group
.
如果您需要API支持或可视滞后监控,可以使用https://github.com/yahoo/kafka-manager
1 回答
.
如果您需要API支持或可视滞后监控,可以使用https://github.com/yahoo/kafka-manager