apache-kafka - 如何通过“out_exec”插件运行 shell 脚本？

Question

有一个日志文件将消息从 FluentD 传递到 Kafka（FluentD --> Kafka）。

Fluentd 配置设置如下。

<source>
@type tail
path /home/ubuntu/demo/files/test
pos_file /home/ubuntu/demo/fluentd/test.log.pos
tag fluentd.example
format none
</source>
<match *.**>
@type kafka_buffered
brokers localhost:9092
default_topic fluentd-example
max_send_retries 1
</match>

每当 FluentD 将消息传递给 Kafka 时，我们都想知道消息是否传递给了 Kafka（确认）。

我觉得，它可能通过“out_exec”流利的插件。如果我错了，请纠正我或建议我还有其他方法。

如何通过“out_exec”插件运行 shell 脚本？

标签： apache-kafkakafka-consumer-apifluentd

Answer 1

required_acks参数呢 ？https://github.com/fluent/fluent-plugin-kafka