我正试图通过ELK堆栈可视化Kafka日志。我特别需要实时查看消费者未读消息的数量。我看过卡夫卡中的日志文件夹，但无法理解。
-
在哪里可以找到与消费者补偿相关的信息，以及如何在弹性搜索中上传这些信息？
-
是否有关于kafka中日志的文档(例如server.log、controller.log(
Kafka的日志文件夹不包含消费者滞后。
您需要从消费者应用程序本身导出这些数据，或者安装Prometheus、Burrow或Remora等外部监控，然后抓取并索引到Elasticsearch 中