如何使用logstash将日志文件写入kafka？

Question

我正在尝试使用 logstash 将我的日志文件发送到 kafka 主题。不确定 logstash 配置文件中需要什么配置才能将输出发送到 kafka。如果有人做过类似的事情，请分享。

Answer 1

Kafka 的 logstash 输出块如下所示：

 output {
    kafka {
        topic_id => "your_topic_id"
    }
}

Here 是文档。