Flink Elasticsearch 接收器成功处理程序

Question

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

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

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

Answer 1

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