Что такое ключ партиционности в Kafka?

Ключ партиционирования (partition key) в Kafka — это значение, по которому определяется, в какой раздел (partition) топика попадёт конкретное сообщение. Он используется для распределения нагрузки и обеспечения порядка сообщений внутри партиции.

Когда продюсер отправляет сообщение, Kafka применяет функцию хеширования к ключу партиционирования, чтобы выбрать конкретный partition. Сообщения с одинаковым ключом всегда попадут в один и тот же partition, что гарантирует их последовательную обработку.

Например, если у вас есть топик с 10 партициями, и ключ — это ID пользователя, то все события одного пользователя будут попадать в одну партицию, сохраняя порядок.