Cristian created FLINK-8162:
-------------------------------
Summary: Kinesis Connector to report millisBehindLatest metric
Key: FLINK-8162
URL: https://issues.apache.org/jira/browse/FLINK-8162
Project: Flink
Issue Type: Improvement
Components: Kinesis Connector
Reporter: Cristian
Priority: Minor
When reading from Kinesis streams, one of the most valuable metrics is
"MillisBehindLatest"
([see](https://github.com/aws/aws-sdk-java/blob/25f0821f69bf94ec456f602f2b83ea2b0ca15643/aws-java-sdk-kinesis/src/main/java/com/amazonaws/services/kinesis/model/GetRecordsResult.java#L187-L201)).
Flink should use its metrics mechanism to report this value as a gauge, tagging
it with the shard id.
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
