【发布时间】:2021-10-15 00:47:20
【问题描述】:
我的 Spring Boot 项目有 4 个模块,我需要使用 Kafka 来建立模块之间的通信。我在我的电脑上安装了 Kafka,并使用 cmd 创建了主题。
问题是,在我提交项目后,除非我的老师在他的计算机上创建了相同的主题(据我了解),否则这些主题将不起作用。
有没有办法确保我的项目自动创建主题?
【问题讨论】:
我的 Spring Boot 项目有 4 个模块,我需要使用 Kafka 来建立模块之间的通信。我在我的电脑上安装了 Kafka,并使用 cmd 创建了主题。
问题是,在我提交项目后,除非我的老师在他的计算机上创建了相同的主题(据我了解),否则这些主题将不起作用。
有没有办法确保我的项目自动创建主题?
【问题讨论】:
是的,您可以使用spring-kafka 依赖并添加一些主题bean
@Bean
public NewTopic topic() {
return TopicBuilder.name("example")....build();
}
https://docs.spring.io/spring-kafka/reference/html/#configuring-topics
【讨论】: