Quarkus@Blocking消费者在多分区主题下为何未生成多实例？

核心结论 #

在你当前的配置下，Quarkus（基于SmallRye Reactive Messaging）不会自动创建多个消费者实例，这就是你只看到in-pool-0线程反复出现、处理缓慢的根本原因。

具体原因 #

1. 默认消费模式限制：@Incoming注解默认仅创建单个消费者实例，即便你的Kafka主题有8个分区，这个单实例会拉取所有分区的消息。
2. 线程池配置的作用范围：你配置的smallrye.messaging.worker.in-pool.max-concurrency=8用于控制线程池的最大并发数，但它只负责执行单消费者实例提交的处理任务——如果单消费者实例串行拉取并提交任务（比如消息键分区逻辑导致所有消息集中到同一处理路径），就会出现始终只用一个线程的情况。
3. 按键分区的误区：消息按键分区仅能保证同键消息进入同一个主题分区，但如果没有多消费者实例绑定不同分区，单消费者仍会从所有分区拉取消息，无法充分利用线程池的并发能力。

解决方法 #

要让消费能力匹配主题分区数，需显式配置消费者实例数量，让每个实例对应一个分区：

1. 添加以下配置（对应你的in-topic）：

   mp.messaging.incoming.in-topic.consumer-count=8
   

   该配置会创建8个消费者实例，每个实例负责一个主题分区，天然实现分区级别的并行消费。
2. 确保线程池的max-concurrency设置不小于消费者实例数，避免线程池成为性能瓶颈。

补充说明 #

配置多消费者实例后，每个实例会独立拉取对应分区的消息，并将处理任务提交到指定的in-pool线程池，此时日志中会出现in-pool-0到in-pool-7的线程，充分利用8个并发处理能力，解决处理缓慢的问题。

内容的提问来源于stack exchange，提问作者user432024