Flink弹性搜索接收器成功处理程序

Question

我使用Flink弹性搜索接收器将记录批量插入到ES。

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

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

Answer 1

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