CODEWITHSUNDEEP
apache-flinkflink-streamingflink-cepflink-batch
Vicky
Vicky

Reputation: 3021

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.

Upvotes: 2

Views: 253

Answers (1)

David Anderson
David Anderson

Reputation: 43514

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

Upvotes: 1

Related Questions