группа
с 3 консьюмерами
сколько сообщений будет взято в 1 момент времени? только 3?
тут надо понять что количество консумеров увеличивают когда упираются в сам процесс вычитки, а вашем случае у вас проблема в молотилке и воркер тредах. Если вы вручную пулите сообщения, то вы ограничены количеством партиций. Но ничего не мешает вам вычитать пачку в 1000 сообщений сформирвоать из них внутреннюю очередь и выполнить на пуле потоков, сосбна примерно так сделано в спринг кафке
Обсуждают сегодня