Spring Kafka为主题配置分区数

Question

是否有可能在Spring Kafka中为特定主题配置分区数量,以便能够有效地使用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启动自动配置a KafkaAdmin @Bean.