Spring Cloud Stream: свойство spring.cloud.stream.default.consumer.concurrency точно означает - PullRequest
0 голосов
/ 18 января 2019

Я хотел бы знать точное значение слова «параллелизм» при использовании свойства spring.cloud.stream.default.consumer.concurrency.

Документация (https://docs.spring.io/spring-cloud-stream/docs/Chelsea.RELEASE/reference/html/_configuration_options.html) говорит "Параллельность входящего потребителя", и это можно интерпретировать несколькими способами.

Какой исполнитель потоков создается за кулисами?

Спасибо!

1 Ответ

0 голосов
/ 19 января 2019

Семантика параллелизма зависит от фактической реализации связующего.Например, в случае механизма связывания Кафки, когда вы устанавливаете параллелизм, это значение будет передано базовому MessageListenerContainer.Допустим, ваше потребительское приложение использует тему из 3 разделов, а для concurrency установлено значение 3. Это создаст 3 потока в контейнере, в котором каждый из них обрабатывает один раздел из темы (ВНа самом деле, в случае связующего Kafka, 3 контейнера слушателя будут созданы за кулисами).Если в теме больше разделов, чем параллельных потоков, то разделы будут распределены по различным потокам.Та же самая семантика применима и к связующему с Кроликом, хотя его фактическая реализация может немного отличаться внутри страны.

Добро пожаловать на сайт PullRequest, где вы можете задавать вопросы и получать ответы от других членов сообщества.
...