Spring为主题配置分区数量

Question

在Spring中是否有可能为特定主题配置分区数量，以便能够有效地使用org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory.setConcurrency(Integer)方法在此主题上并行用户，从而加快消息消耗和处理？如果是的话，你能不能给我举个例子，说明如何做到这一点。

Answer 1

见配置主题。

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

将创建一个主题foo，其中包含10个分区，复制因子为2(如果应用程序上下文中有KafkaAdmin bean )。

Spring自动引导-配置KafkaAdmin @Bean。