Fluentd продолжает читать и продвигать файл .pos, даже когда буфер заполнен, а Elasticsearch не работает ⇐ Python

[Anonymous]

Я использую Fluentd с плагином in_tail и выходом Elasticsearch_data_stream. Моя настройка пишет журналы из многих стручков в центральный NFS. Fluentd хвостает файлы журналов из этого общего NFS и перенаправляет их в Elasticsearch. < /P>
Проблема состоит в том, чтобы:
, когда Elasticsearch (eck) не работает, а буфер fluentd заполняется (я использую файл @type, блок overflow_action и retry_forever true), я ожидаю, что Fluentd останавливает logs и free -файл. Но Fluentd продолжает читать и продвигать смещения .pos, даже если ничего не промывается. Это вызывает постоянную потерю данных, если FluentD перезагружается или сбои. Сценарий? 1.16.9
Elasticsearch: 8.15

Подробнее здесь: https://stackoverflow.com/questions/796 ... full-and-e