Что хотят услышать интервьюеры:

Нужно использовать ключ сообщения и один и тот же способ его вычисления для всех сообщений клиента. Kafka по ключу стабильно выбирает партицию, поэтому сообщения с одинаковым ключом будут попадать в одну и ту же партицию. Если важно именно “один клиент — одна партиция”, то ключом обычно делают clientId или другой стабильный идентификатор клиента.

Определение:

В Kafka выбор партиции для сообщения зависит от ключа сообщения и алгоритма партиционирования. Если у всех сообщений одного клиента одинаковый ключ, продюсер будет отправлять их в одну партицию. Это позволяет сохранить порядок сообщений внутри этого клиента в рамках одной партиции.

Пример использования:

Например, для всех событий одного пользователя в ключ кладут его userId. Тогда все сообщения с userId = 42 будут попадать в одну партицию.

ProducerRecord<String, String> record =
        new ProducerRecord<>("events-topic", "client-42", "{\"type\":\"order_created\"}");

producer.send(record);

Если нужен более контролируемый вариант, можно явно задавать партицию в ProducerRecord, но тогда придется самому распределять клиентов по партициям.

Пояснение кода:

В примере "client-42" — это ключ сообщения.
Kafka использует этот ключ, чтобы вычислить партицию.
Пока ключ не меняется, все сообщения этого клиента будут маршрутизироваться одинаково.
Если вместо ключа передать partition, сообщение уйдет строго в указанную партицию, но это уже ручное управление распределением.

Ключевые моменты:

Для “один клиент — одна партиция” используйте стабильный ключ, например clientId.
Одинаковый ключ у сообщений гарантирует попадание в одну партицию.
Это помогает сохранять порядок сообщений внутри клиента.
Если партиций станет меньше или изменится стратегия партиционирования, распределение может измениться только при смене конфигурации/топологии, поэтому ключ должен быть стабильным.
Если нужно жестко закрепить клиента за партицией, можно задавать партицию вручную, но это хуже масштабируется.

Как обеспечить, чтобы все сообщения одного клиента записывались в одну партицию в Kafka?