use*_*509 6 python distributed message-queue apache-kafka
我正在尝试定期检查 Kafka 中某个主题的队列大小。虽然，我什至不知道如何检查该指标甚至一次。我对 Kafka 完全陌生，所以我不确定该怎么做。我认为这将涉及创建生产者或消费者来与队列进行交互，但我遇到了障碍。
我认为目前不可能。您应该将 Kafka 主题视为无限数据流，因此在我看来，您唯一的选择是计算消费者中已消费的消息。
您可以使用kafka偏移监控工具，它将显示每个主题分区的日志大小（您必须总结）：http://ingest.tips/2014/10/12/kafka-high-level-consumer-frequently-缺失的部分/
| 归档时间： |
|
| 查看次数： |
14625 次 |
| 最近记录： |