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 :)
---