版本1.11.2
用这种方式FlinkKafkaProducer(String topicId, SerializationSchema<IN>
serializationSchema, Properties producerConfig)生产没问题,数据写入无报错
这种方式
FlinkKafkaProducer(
String defaultTopicId,
KeyedSerializationSchema<IN> serializationSchema,
Properties producerConfig,
Optional<FlinkKafkaPartitioner<IN>> customPartitioner)
就会报上面的错误,不知为何,哪位大佬解答下
--
Sent from:
http://apache-flink.147419.n8.nabble.com/