当试图产生关于Kafka的信息时,不断得到log:reactor.core.Exceptions$ErrorCallbackNotImplemented: org.apache.kafka.common.errors.TimeoutException: Topic topic not present in metadata after 60000 ms. Caused by: org.apache.kafka.common.errors.TimeoutException: Topic topic not present in metadata after 60000 ms.
。
已经确保我有Jackson核心,Jackson数据绑定和Kafka客户端依赖关系的生产者项目。此外,我如何通过安全协议在React堆KafkaSenderOptions
1条答案
按热度按时间ycl3bljg1#
Topic topic not present in metadata after 60000 ms.
您必须先创建主题,然后才能使用它-无论是通过命令行工具还是通过AdminClient
。您可以在传递到
create()
的Map中设置任何ProducerConfig
属性。