[GitHub] flink pull request #5182: [FLINK-8162] [kinesis-connector] Emit Kinesis' mil...

[tzulitai]

Github user tzulitai commented on a diff in the pull request:

    https://github.com/apache/flink/pull/5182#discussion_r158161267
  
    --- Diff: 
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/internals/ShardConsumer.java
 ---
    @@ -96,6 +99,15 @@ protected ShardConsumer(KinesisDataFetcher<T> fetcherRef,
                                                        SequenceNumber 
lastSequenceNum,
                                                        KinesisProxyInterface 
kinesis) {
                this.fetcherRef = checkNotNull(fetcherRef);
    +           MetricGroup kinesisMetricGroup = fetcherRef.getRuntimeContext()
    +                   .getMetricGroup()
    +                   .addGroup("Kinesis")
    --- End diff --
    
    Would be best if @zentol also comments on this.


---