Hi!
All properties you set by calling KafkaSource.builder().setProperty() will
also be given to KafkaConsumer (see [1]). However these two properties are
specific to Flink and Kafka does not know them, so Kafka will produce a
warning message. These messages are harmless as long as the properties
Hi Team,
I am trying to set the following properties in Kafka Source API in flink
1.14.3 version.
-> client.id.prefix
-> partition.discovery.interval.ms
But I am getting the below mentioned warning in taskmanager logs:
1. WARN org.apache.kafka.clients.consumer.ConsumerConfig [] -
