#apache-flink #flink-streaming #flink-cep #flink-batch
#apache-flink #flink-потоковая передача #flink-cep #flink-batch
Вопрос:
Я использую Flink Elasticsearch sink для массовой вставки записей в ES.
Я хочу выполнить операцию после успешной синхронизации записи с Elasticsearch. Существует обработчик сбоев, с помощью которого мы можем повторить ошибки. Есть ли обработчик успеха в приемнике flink elasticsearch?
Примечание: я не смог выполнить операцию перед добавлением записи в массовый процессор, потому что нет гарантии, что запись синхронизирована с ES? Я хочу выполнить операцию только после синхронизации записи с Elasticsearch.
Ответ №1:
Я не верю, что приемник Elasticsearch предлагает эту функцию. Я думаю, вам придется расширить приемник, чтобы добавить эту функциональность.
Комментарии:
1. что вы имеете в виду
extend the sink?2. Я имею в виду реализацию нового приемника путем расширения (в смысле Java) или создания подклассов соответствующих классов из существующего приемника, чтобы добавить эту функциональность.