将日志从kafka传输到elasticsearch

Question

我正在寻找可以直接将我的日志从kafka传输到elasticsearch的轻量级日志发送器。在 Filebeat、Logagent、Logstash（但我需要轻量级）中，哪些最适合我的用例？

Answer 1

rsyslog is lightweight. As from version 8.27, it supports kafka 作为输入。甚至更早的时候就支持 Elasticsearch 作为输出。

描述了Kafka输入模块配置here

描述了 Elasticsearch 输出模块配置 here