用spring kafka 2.5.8版本实现每个kafka主题分区一个用户线程

Question

我一直在使用apache kafka-clients（确切地说是2.3.1版本）库来创建kafka使用者，其中一个分区一个使用者线程是通过以下计算实现的：

计算上的使用者线程数*计算数=主题的分区数

它过去是手动伸缩的，因此当需要增加计算的数量时，在一台计算机上运行的使用者线程不会相应减少。

我们如何使用org.springframework.kafka.config.concurrentKafKalistenerContainerFactory实现这一点。

我正在尝试使用spring kafka 2.5.8版本。该应用程序运行在具有自动伸缩功能的k8s集群上。假设我把最大和最小豆荚设置为4，所以理想情况下

4 X使用者线程数=主题的分区数

如何配置这个使用者线程数。是通过这个：

Answer 1

是；或者@kafkalistener上的concurrency属性，该属性重写工厂的并发性。

如果您在运行时更改它，它将不会生效，除非您stop()和start()容器。