有没有可能在SpringKafka中为特定主题配置分区的数量，以便能够有效地使用 org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory.setConcurrency(Integer) 如何在这个主题上对消费者进行并行处理，以加快消息的消耗和处理？如果是这样的话，请举例说明如何做到这一点。
org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory.setConcurrency(Integer)
qzwqbdag1#
请参阅配置主题。
@Bean public NewTopic topic1() { return new NewTopic("foo", 10, (short) 2); }
将创建一个主题 foo 有10个分区，复制因子为2（如果有 KafkaAdmin 应用程序上下文中的bean）。spring boot自动配置KafkaAdmin @Bean .
foo
KafkaAdmin
@Bean
1条答案
按热度按时间qzwqbdag1#
请参阅配置主题。
将创建一个主题
foo有10个分区，复制因子为2（如果有KafkaAdmin应用程序上下文中的bean）。spring boot自动配置
KafkaAdmin
@Bean.