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