有一个日志文件将消息从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（确认）。
我觉得，这可能是通过“outexec”fluentd插件。如果我错了，请纠正我，或者建议我还有其他方法。
如何通过“outexec”插件运行shell脚本？