Robert Metzger created FLINK-4004:
-------------------------------------
Summary: Do not pass custom flink kafka connector properties to Kafka to avoid warnings
Key: FLINK-4004
URL:
https://issues.apache.org/jira/browse/FLINK-4004 Project: Flink
Issue Type: Improvement
Components: Kafka Connector
Reporter: Robert Metzger
The FlinkKafkaConsumer has some custom properties, which we pass to the KafkaConsumer as well (such as {{flink.poll-timeout}}). This causes Kafka to log warnings about unused properties.
We should not pass Flink-internal properties to Kafka, to avoid those warnings.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)