我正在尝试使用 Spring Boot 在 Kafka 中创建一个新主题。
在谷歌搜索后,我得到了以下答案
@Configuration
public class KafkaTopicConfiguration {
@Bean
public NewTopic createTopic(Topic topic) {
return TopicBuilder.name(topic.getTopicName())
.partitions(topic.getPartitions())
.replicas(topic.getReplicas())
.build();
}
}
但我无法使用 Spring Boot REST POST 调用实现以下内容。
@PostMapping("/api/v1/kafkatopic/")
public NewTopic createTopic(@RequestBody Topic topic)
{
return kt.createTopic(topic);
}
//kt being object of the Configuration Class
但如果主题详细信息已沿代码传递(硬编码),则相同的代码会起作用,如下所示。
@Bean
public NewTopic createTopic() {
return TopicBuilder.name("test-topic")
.partitions(6)
.replicas(3)
.build();
}
有人可以帮忙吗
提前致谢
最佳答案
NewTopic
bean 仅在应用程序初始化期间创建。在运行时调用 bean 工厂方法什么都不做。
要动态创建主题,您需要使用AdminClient
。 Spring Boot 自动配置一个 KafkaAdmin
bean。
您可以使用其属性创建一个 AdminClient
。
然后使用客户端创建您的主题。
try (AdminClient client = AdminClient.create(kafkaAdmin.getConfigurationProperties()) {
...
}
关于spring-boot - 使用 Spring Boot 创建 Kafka 主题,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/68347459/