Где распределяются партиции

Партиции распределяются в Kafka брокерах. Каждая партиция принадлежит одному брокеру (leader), но может реплицироваться на другие брокеры (followers) для отказоустойчивости. Распределение контролируется партиционированием:

1. По умолчанию – используется хэш ключа сообщения (key % число_партиций). Если ключ null, применяется round-robin.
2. Кастомное – можно реализовать интерфейс Partitioner.

Пример:

// Создание продюсера с кастомным партиционером
props.put("partitioner.class", "com.example.CustomPartitioner");

Партиции физически хранятся как директории на диске брокера в формате topic-partition. Например, orders-0, orders-1.