[GitHub] flink pull request #5992: [FLINK-8944] [Kinesis Connector] Use listShards in...

[kailashhd]

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

    https://github.com/apache/flink/pull/5992#discussion_r189417750
  
    --- Diff: 
flink-connectors/flink-connector-kinesis/src/main/java/org/apache/flink/streaming/connectors/kinesis/util/KinesisConfigUtil.java
 ---
    @@ -181,6 +181,25 @@ public static Properties 
replaceDeprecatedProducerKeys(Properties configProps) {
                return configProps;
        }
     
    +   public static Properties replaceDeprecatedConsumerKeys(Properties 
configProps) {
    +           if 
(configProps.containsKey(ConsumerConfigConstants.STREAM_DESCRIBE_BACKOFF_BASE)) 
{
    --- End diff --
    
    Done.


---