6 bölməli mövzuda əlavə 6 bölmə əlavə olundu. Açar — userID. Eyni açarla mesaj eyni bölməyə gedəcəkmi?

В Kafka партиция определяется с помощью хеш-функции от ключа сообщения по модулю количества партиций. Если в топике было 6 партиций, и добавили ещё 6 (всего 12), то при изменении количества партиций хеширование изменится.

Это значит, что сообщение с тем же ключом userID, скорее всего, попадёт в другую партицию, так как количество партиций влияет на вычисление индекса партиции:

partition = hash(key) % num_partitions

Из-за этого при увеличении числа партиций сообщения с одним и тем же ключом могут распределяться по другим партициям, что может повлиять на порядок обработки сообщений с этим ключом.

Для сохранения консистентного распределения ключей обычно создают топики с фиксированным числом партиций или используют специальные стратегии партиционирования.