[GitHub] flink pull request #6387: [FLINK-9846] [table] Add a Kafka table sink factor...

[pnowojski]

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

    https://github.com/apache/flink/pull/6387#discussion_r204351288
  
    --- Diff: 
flink-connectors/flink-connector-kafka-base/src/main/java/org/apache/flink/streaming/connectors/kafka/KafkaTableSourceSinkFactoryBase.java
 ---
    @@ -125,89 +131,47 @@
     
        @Override
        public StreamTableSource<Row> createStreamTableSource(Map<String, 
String> properties) {
    -           final DescriptorProperties params = new 
DescriptorProperties(true);
    -           params.putProperties(properties);
    +           final DescriptorProperties descriptorProperties = 
getValidatedProperties(properties);
    --- End diff --
    
    +1 for this changes here :)


---