Блог

У меня есть вариант использования множества групп потребителей (и по одной теме на группу потребителей), поэтому мне нужно создать множество экземпляров ConcurrentMessageListenerContainer, каждый для одной темы/группы потребителей. Но я бы хотел, чтобы они использовали общий пул потоков, чтобы контролировать вызовы kafkaconsumer.опрос, а также то, как обрабатываются записи. Как вы думаете, уместно ли это делать с spring kafka, или мне нужно реализовать свою собственную версию, создающую собственные экземпляры KafakConsumers ?

Использование пула не поможет — в настоящее время контейнер использует выделенный поток для каждого потребителя. Нет поддержки совместного использования потоков между контейнерами.