я понимаю, что эквивалентно, когда из 3 партиций читает 3 консьюмера и из 3 партиций читает один консьюмер у которого concurrency 3?
зависит от имплементации клиентской части у консьюмера какую библиотеку используете?
в общем и целом - да за исключением менеджмента соединений и подобных оптимизационных вещей.
Еще такой момент услышал, что в принципе если партиций 10 и указать поток 100 То спринг сделает все по умному и будет использовать только 10 потоков Это верное утверждение?
вот это не знаю, надо курить доки, ну или проверять. или еще кто подскажет тут
Понял Спасибо тебе большое
Это не заслуга spring, а логика работы Kafka - в рамках одной group.id не может быть больше одновременно работающих потребителей, чем количество партиций так что возможно что spring и поднимет 100 потоков, но данные будут поступать только к 10 из них, остальные будут спать
ну, тут вопрос в том, что вот в одном потоке получили данные, а потом их обработку не параллелит ли спринг? я с большой долей уверенности могу сказать, что нет но лучше перепроверить.
Обсуждают сегодня