Search code examples
apache-flinkflink-streamingflink-cepflink-batch

Flink Elasticsearch sink success handler

I use Flink Elasticsearch sink to bulk insert the records to ES.

I want to do an operation after the record is successfully synced to Elasticsearch. There is a failureHandler by which we can retry failures. Is there a successHandler in flink elasticsearch sink?

Note: I couldn't do the operation before adding the record to the bulk-processor because there is no guarantee that the record is synced with ES? I want to do the operation only after the record is synced to Elasticsearch.

Solution

  • I don't believe the Elasticsearch sink offers this feature. I think you will have to extend the sink to add this functionality.