Flink Elasticsearch sink 成功处理程序

Question

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

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

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

Answer 1

我不相信 Elasticsearch 接收器提供此功能。我认为您必须扩展接收器才能添加此功能。