spring @Beanを使用してカフカトピックを作成していますか？

Question

spring beanを使ってカフカトピックを作成することは可能ですか？ RabbitMQのQueueとTopicExchangesは、プログラムでこれらのように作成できます。

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

ドキュメンテーションがうまくいきませんでした。

Answer 1

はい、最新のSpring Kafkaバージョン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改善可能であるという点で負担します。