org.apache.flink.streaming.connectors.kafka.FlinkKafkaException: Failed to send data to Kafka: Topic not present in metadata after 60000 ms.

Thu, 17 Dec 2020 23:53:16 -0800 

版本1.11.2
用这种方式FlinkKafkaProducer(String topicId, SerializationSchema<IN>
serializationSchema, Properties producerConfig)生产没问题，数据写入无报错

这种方式
FlinkKafkaProducer(
                String defaultTopicId,
                KeyedSerializationSchema<IN> serializationSchema,
                Properties producerConfig,
                Optional<FlinkKafkaPartitioner&lt;IN>> customPartitioner) 
就会报上面的错误，不知为何，哪位大佬解答下




--
Sent from: http://apache-flink.147419.n8.nabble.com/

回复