创建卡夫卡的话题？

Question

是否有可能使用的Spring bean创建卡夫卡的话题。就像我们的队列，并且可以创建编程像这些在RabbitMQ的TopicExchanges。

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

试过文档无法得到很多帮助。

Answer 1

是的，现在可以使用最新的Spring卡夫卡版本1.3：https://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的卡夫卡0.11.0.x改进。