版本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/