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

【问题标题】：How to run shell script through "out_exec" plugin?如何通过“out_exec”插件运行 shell 脚本？
【发布时间】：2019-05-13 03:35:12
【问题描述】：

有一个日志文件将消息从 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-kafka kafka-consumer-api fluentd

【解决方案1】：

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

【讨论】：

在哪里可以看到确认消息？