[GitHub] flink pull request #6021: [FLINK-9374] [kinesis] Enable FlinkKinesisProducer...

[fmthoma]

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

    https://github.com/apache/flink/pull/6021#discussion_r192861304
  
    --- Diff: 
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
 ---
    @@ -180,9 +204,16 @@ public void open(Configuration parameters) throws 
Exception {
                KinesisProducerConfiguration producerConfig = 
KinesisConfigUtil.getValidatedProducerConfiguration(configProps);
     
                producer = getKinesisProducer(producerConfig);
    +
    +           final MetricGroup kinesisMectricGroup = 
getRuntimeContext().getMetricGroup().addGroup("kinesisProducer");
    --- End diff --
    
    Sure.


---