Hi Satish, The Elasticsearch sink uses the new Sink, so the only possible metrics that it can send by default are the ones documented in FLIP-33 [1]. Since the JDBC connector doesn't use these interfaces, I don't think these metrics are available out of the box.
Best regards, Martijn [1] https://cwiki.apache.org/confluence/display/FLINK/FLIP-33%3A+Standardize+Connector+Metrics Op vr 16 sep. 2022 om 01:23 schreef Satish Saley <satishsa...@apache.org>: > Hi folks, > I use the following to interact with databases and elasticsearch. > > org.apache.flink.connector.jdbc.table.JdbcTableSource > org.apache.flink.streaming.connectors.elasticsearch7.ElasticsearchSink > > Do these connectors provide any metrics out of the box? Metrics such as > - QPS to database, Elasticsearch > - Latency for DB queries, Elasticsearch requests > - Success/Failure >
