我使用flink1.12版本,采用flink-kafka-connector从kafka的topicA中读取数据,然后sink会topicB,在sink to topicB的FlinkProducer设置如下时,程序会偶现报错,去掉后异常消失,请问是什么原因呢?
flinkKafkaProducer.setWriteTimestampToKafka(true); -- Sent from: http://apache-flink.147419.n8.nabble.com/
我使用flink1.12版本,采用flink-kafka-connector从kafka的topicA中读取数据,然后sink会topicB,在sink to topicB的FlinkProducer设置如下时,程序会偶现报错,去掉后异常消失,请问是什么原因呢?
flinkKafkaProducer.setWriteTimestampToKafka(true); -- Sent from: http://apache-flink.147419.n8.nabble.com/