Там есть файл журнала, который доставляет сообщение из 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 доставляет сообщение Кафке, мы хотели бы знать, доставлено ли сообщение Кафке или нет (подтверждение).
Я чувствую, это возможно через плагин "out_exec". Поправьте меня, если я ошибаюсь, или подскажите, есть ли другие способы.
Как запустить скрипт оболочки через плагин "out_exec"?