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

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

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

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