我正在使用spring-kafka,我希望它在启动时自动创建我的主题。我通过在我的configuration类中添加@Bean NewTopic来配置它。但是,这似乎没有执行,因为在前面我在日志中看到的情况下,来自apache-kafka的apache-kafka正在“发送元数据请求”,然后响应说:
topics=[MetadataResponseTopic(errorCode=3和Error while fetching metadata with correlation id 2 : {my.topic.name=UNKNOWN_TOPIC_OR_PARTITION}
然后重复60秒(max.block.ms),最后停止整个应用程序,因为Spring无法初始化所有bean,因为缺少这个主题。似乎NewTopic bean没有机会被调用并完成它的工作。
有人知道怎么回事吗?
我可以在这里以任何方式控制事物的执行顺序,以便在spring初始化bean时,在它们开始执行任务之前调用NewTopic (并创建实际的主题)(尝试向尚未存在的主题发送一些内容)。
发布于 2022-10-09 12:58:43
因此,正如@Artem建议的那样,问题是我的Spring在初始化时已经执行了一些代码,这些代码涉及到与Kafka的交互,因此- spring没有完全初始化bean,因为它在使用NewTopic之前崩溃了。
https://stackoverflow.com/questions/73938224
复制相似问题