java – 用spring管理Kafka主题

我们计划在我们的应用程序中使用Kafka排队.我在RabbitMQ和Spring方面有一些经验.

使用RabbitMQ和Spring,我们曾经在启动spring服务时管理队列创建.

有了Kafka,我不确定什么是创建主题的最佳方式？有没有办法用Spring管理主题.

或者,我们应该编写一个单独的脚本来帮助创建主题吗？维护一个单独的脚本来创建主题对我来说似乎有点奇怪.

任何建议将不胜感激.

解决方法:

在Spring中,可以使用bean在应用程序启动期间创建主题：

@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);
}

或者,您可以通过自动装配AdminClient来编写自己的创建主题,例如,从输入文件中读取列表或指定高级属性(如分区号)：

@Autowired
private KafkaAdmin admin;
//...your implementation

另请注意,因为默认情况下启用了Kafka 1.1.0 auto.create.topics.enable(see Broker configs).

有关更多信息,请参阅spring-kafka docs

标签：java,spring-boot,apache-kafka,spring-kafka,rabbitmq
来源： https://codeday.me/bug/20190910/1800746.html