[GitHub] flink pull request #5991: [FLINK-9303] [kafka] Adding support for unassign d...

[EAlexRojas]

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

    https://github.com/apache/flink/pull/5991#discussion_r188564095
  
    --- Diff: 
flink-connectors/flink-connector-kafka-0.8/src/main/java/org/apache/flink/streaming/connectors/kafka/FlinkKafkaConsumer08.java
 ---
    @@ -221,7 +221,8 @@ private FlinkKafkaConsumer08(
                                getLong(
                                        checkNotNull(props, "props"),
                                        
KEY_PARTITION_DISCOVERY_INTERVAL_MILLIS, PARTITION_DISCOVERY_DISABLED),
    -                           !getBoolean(props, KEY_DISABLE_METRICS, false));
    +                           !getBoolean(props, KEY_DISABLE_METRICS, false),
    +                           getBoolean(props, KEY_CHECK_UNAVAILABLE_TOPICS, 
false));
    --- End diff --
    
    You're right, I'll change it


---