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             [] -
The configuration 'client.id.prefix' was supplied but isn't a known config.
2. WARN  org.apache.kafka.clients.consumer.ConsumerConfig             [] -
The configuration 'partition.discovery.interval.ms' was supplied but isn't
a known config.

What could be the reason for this warning?

Also, in flink version 1.13.2 we were able write timestamp to kafka
using setWriteTimestampToKafka(true) method of FlinkKafkaProducer class.
Similar to this how can we write timestamp to kafka using KafkaSink API in
flink 1.14.3?

Any leads would be appreciated.

Thanks and Regards
Mahima Agarwal

Reply via email to