apache-flink - Flink Elasticsearch sink 成功处理程序

Question

我使用 Flink Elasticsearch sink 将记录批量插入到 ES。

我想在记录成功同步到 Elasticsearch 后做一个操作。有一个 failureHandler ，我们可以通过它重试失败。flink elasticsearch sink中是否有successHandler？

注意：在将记录添加到批量处理器之前我无法执行此操作，因为不能保证记录与 ES 同步？我只想在记录同步到 Elasticsearch 后进行操作。

Answer 1

我不相信 Elasticsearch 接收器提供此功能。我认为您将不得不扩展接收器以添加此功能。