Я использую KafkaListener для прослушивания нескольких тем, и каждая тема имеет 20 разделов, и ниже приведена моя конфигурация. Итак, здесь Каждая тема будет иметь одни и те же 20 потоков (ИЛИ) каждая тема получит свои 20 потоки ?
импортировать org.springframework.kafka.annotation.KafkaListener;
KafkaListener(topics = { "topic1", "topic2","topic3"},
concurrency = "20",
clientIdPrefix = "client1",
groupId = "group1")




Будет 20 потоков, каждый из которых использует один раздел каждой темы.
Если вам нужны отдельные потоки, вы можете добавить к методу 3 аннотации @KafkaListener, каждая из которых настроена на 1 тему, или установить параллелизм на 60 и использовать настраиваемое средство назначения разделов, чтобы убедиться, что каждый потребитель получает только один раздел.