Hi Gordon, I commented the ticket. What would you think I start to implement it as there is no progress recently?
I see it's only about adding metrics in the following class? and anyway I probably would have to build it soon. https://github.com/apache/flink/blob/master/flink-connectors/flink-connector-elasticsearch-base/src/main/java/org/apache/flink/streaming/connectors/elasticsearch/ElasticsearchSinkBase.java Cheers, Sendoh -- Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/