@Kafkalistener单主题单分区

Question

我使用spring-kafka注释@kafkalistener来指定我的侦听器方法。

我使用单个分区的单个主题。消息永远不会超过一秒或两秒，所以单个线程是可以接受的。spring-kafka文档称@Kafkalistener默认使用ConcurrentMessageListenerContainer。使用SetConcurrency控制并发的正确方法是吗？

    @Bean("appContainerFactory")
    KafkaListenerContainerFactory<ConcurrentMessageListenerContainer<Integer, String>>
    kafkaListenerContainerFactory() {
    ConcurrentKafkaListenerContainerFactory<Integer, String> factory = new ConcurrentKafkaListenerContainerFactory<>();
    factory.setConcurrency(1);
    ...
    }

Answer 1

使用SetConcurrency控制并发的正确方法是吗？

您所拥有的是正确的，但是容器上的默认concurrency是1，因此在不需要并发时不必指定它。

或者，我应该创建一个KafkamessageListenerContainer，它是单线程的吗？

并发容器为每个并发旋转一个“子”KafkamessageListenerContainer，所以只为您创建了一个。