Что такое партиция в Kafka

Партиция — это упорядоченная, неизменяемая последовательность сообщений в топике Kafka. Каждый топик делится на одну или несколько партиций для горизонтального масштабирования и параллельной обработки.

Ключевые особенности:

• Сообщения в партиции упорядочены по времени (по offset)
• Каждая партиция хранится на отдельном брокере (реплицируется для отказоустойчивости)
• Позволяет распределять нагрузку между consumer'ами (1 партиция = 1 consumer в группе)

Пример создания топика с партициями:

AdminClient admin = AdminClient.create(props);
NewTopic topic = new NewTopic("orders", 3, (short) 1); // 3 партиции
admin.createTopics(Collections.singleton(topic));