Интеграция Spring Kafka MessaheChannel Thread?

У меня есть компонент потока Spring Integration (настроенный через Java DSL), который обрабатывает сообщения из канала сообщений очереди kafka, связанного с Spring CloudStream.

Источником сообщения kafka является внешнее приложение, поэтому я действительно хочу понять, какие потоки/потоки будут фактически обрабатывать эти сообщения.

Это один выделенный поток, созданный с помощью приложения, или пул потоков, созданный и настроенный автоматически CloudStream, или что-то еще?

И можно ли как-то с этим справиться?




Ответы (1)


Связыватель канала сообщений kafka по умолчанию использует один поток; если вы увеличите свойство привязки consumer.concurrency, вы получите это количество потоков — вам нужно как минимум столько же разделов, сколько указано в параметре concurrency, потому что раздел может использоваться только одним потребителем.

person Gary Russell    schedule 23.07.2020