[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_r197141591
  
    --- Diff: 
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/FlinkKinesisProducer.java
 ---
    @@ -55,6 +58,13 @@
     @PublicEvolving
     public class FlinkKinesisProducer<OUT> extends RichSinkFunction<OUT> 
implements CheckpointedFunction {
     
    +   public static final String KINESIS_PRODUCER_METRIC_GROUP = 
"kinesisProducer";
    +
    +   public static final String METRIC_BACKPRESSURE_CYCLES = 
"backpressureCycles";
    +
    +   public static final String METRIC_OUTSTANDING_RECORDS_COUNT = 
"outstandingRecordsCount";
    +
    +
    --- End diff --
    
    ✔


---