使用spring @Bean创建kafka主题?

spring-boot apache-kafka spring-kafka

2341 观看

1回复

3451 作者的声誉

是否可以使用Spring bean创建kafka主题。就像我们在RabbitMQ中拥有Queue和TopicExchanges一样,可以像这样以编程方式创建它们。

@Bean
Queue queue(){
  return new Queue("name");
}

试图文档无法获得太多帮助。

作者: Barath 的来源 发布者: 2017 年 9 月 15 日

回应 1


3

73942 作者的声誉

决定

是的,现在可以使用最新的Spring Kafka版本1.3https : //docs.spring.io/spring-kafka/docs/1.3.0.RC1/reference/html/_reference.html#_configuring_topics

@Bean
public KafkaAdmin admin() {
    Map<String, Object> configs = new HashMap<>();
    configs.put(AdminClientConfig.BOOTSTRAP_SERVERS_CONFIG,
            StringUtils.arrayToCommaDelimitedString(kafkaEmbedded().getBrokerAddresses()));
    return new KafkaAdmin(configs);
}

@Bean
public NewTopic topic1() {
     return new NewTopic("foo", 10, (short) 2);
}

但是请记住,由于Apache Kafka的0.11.0.x改进,这是可能的。

作者: Artem Bilan 发布者: 2017 年 9 月 15 日
32x32