我试图通过麋鹿堆来想象Kafka的日志。我特别需要实时查看消费者未读的信息数量。我看过Kafka的日志文件夹,但无法理解。我在哪里可以找到与消费者补偿相关的信息,如何在elasticsearch中上传这些信息?kafka中是否有关于日志的文档(例如server.log、controller.log)
643ylb081#
Kafka的日志文件夹不支持用户延迟。您需要从消费者应用程序本身导出这些数据,或者安装外部监控,比如prometheus、burrow或remora,然后将这些数据刮入elasticsearch并编制索引
1条答案
按热度按时间643ylb081#
Kafka的日志文件夹不支持用户延迟。
您需要从消费者应用程序本身导出这些数据,或者安装外部监控,比如prometheus、burrow或remora,然后将这些数据刮入elasticsearch并编制索引