如何在Spingboot中确定消费群体中的消费者数量？

Question

我使用注释@KafkaListner来听一个特定的主题。然而，突然间，我注意到消费者在接收生产者的信息方面有很大的滞后。然后，我增加了代理的分区数，并解决了这个问题。

经过一些研究，我意识到消费者群体中的消费者数量不能超过分区的数量，否则一些消费者将处于非活动状态。

那么在Spring中，是否每个人@KafkaListener都被认为是一个单一的消费者？如果没有，我如何才能找到消费者组中消费者的确切数量，从而能够正确地配置分区？

Answer 1

是否认为每个@KafkaListener都是单一的消费者？

不，它是一个使用者组，可以有一个(默认)或多个使用者线程(容器)。可以使用concurrency属性覆盖ContainerFactory默认属性。

正如您所了解的，主题分区的数量决定了并行性的级别。如果并发性大于分区数，则对并发性进行向下调整，使每个容器获得一个分区。