我一直在使用apache kafka客户端（确切地说是2.3.1版）库来创建kafka使用者，其中一个分区-一个使用者线程是通过以下计算实现的：
计算上的使用者线程数*计算数=主题的分区数
它过去是手动缩放的，因此当需要减少计算数量时，在一台计算机上运行的使用者线程的数量也相应减少。
我们如何使用 org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory .
我正在尝试使用SpringKafka 2.5.8版本。该应用程序在k8s群集上运行，具有自动扩展功能。假设我将max和min pods设置为4，那么理想情况下
4 x使用者线程数=主题的分区数
如何配置此数量的使用者线程。是通过这个： org.springframework.kafka.config.ConcurrentKafkaListenerContainerFactory.setConcurrency() . 有人能给我引路吗。