concurrency = 3 — три потребителя в группе внутри экземпляра, по 2 партиции на каждого. При concurrency = 10 и 6 партициях 4 потребителя простаивают: партиция в группе читается одним потребителем.
А ещё Порядок сохраняется внутри партиции
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
Listener container создаёт указанное число потребителей внутри одной группы, и брокер распределяет между ними партиции. Поскольку партиция в каждый момент принадлежит ровно одному потребителю группы, число партиций задаёт потолок параллелизма — потребители сверх этого числа просто не получат работы, оставаясь резервом на случай отказа. Отсюда практическое следствие для планирования: масштабируемость закладывается при создании топика выбором количества партиций, а увеличить их позже можно, но это ломает привязку ключей к партициям и, значит, гарантию порядка для существующих ключей. Порядок при этом гарантирован только внутри партиции, поэтому связанные события отправляют с одним ключом.
Один верный вариант. Подумайте, потом откройте ответ.
KafkaTemplate, @KafkaListener, listener containers, offset ack, error handling, retries и DLT.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.
sotto