Flink Elasticseach success handler

[Vignesh Ramesh <vi...@gmail.com>]

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.