Весенний слушатель Кафки

Я использую KafkaListener для прослушивания нескольких тем, и каждая тема имеет 20 разделов, и ниже приведена моя конфигурация. Итак, здесь Каждая тема будет иметь одни и те же 20 потоков (ИЛИ) каждая тема получит свои 20 потоки ?

импортировать org.springframework.kafka.annotation.KafkaListener;

KafkaListener(topics = { "topic1", "topic2","topic3"},
        concurrency = "20",
        clientIdPrefix = "client1",
        groupId = "group1")
Пользовательский скаляр GraphQL
Пользовательский скаляр GraphQL
Листовые узлы системы типов GraphQL называются скалярами. Достигнув скалярного типа, невозможно спуститься дальше по иерархии типов. Скалярный тип...
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
Как вычислять биты и понимать побитовые операторы в Java - объяснение с примерами
В компьютерном программировании биты играют важнейшую роль в представлении и манипулировании данными на двоичном уровне. Побитовые операции...
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Поднятие тревоги для долго выполняющихся методов в Spring Boot
Приходилось ли вам сталкиваться с требованиями, в которых вас могли попросить поднять тревогу или выдать ошибку, когда метод Java занимает больше...
Полный курс Java для разработчиков веб-сайтов и приложений
Полный курс Java для разработчиков веб-сайтов и приложений
Получите сертификат Java Web и Application Developer, используя наш курс.
0
0
544
1
Перейти к ответу Данный вопрос помечен как решенный

Ответы 1

Ответ принят как подходящий

Будет 20 потоков, каждый из которых использует один раздел каждой темы.

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

Другие вопросы по теме