Кто определяет количество партиций в Kafka на текущей работе

Количество партиций в Kafka определяется при создании топика и задаётся в параметре num.partitions. Это можно сделать:

1. Через конфигурацию брокера (значение по умолчанию)
2. Явно при создании топика через CLI или API
3. Автоматически (если включено auto-topic creation)

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

kafka-topics --create --topic my-topic --partitions 3 --replication-factor 1 --bootstrap-server localhost:9092

Важные нюансы:

• Уменьшить количество партиций после создания нельзя
• Увеличить можно, но это может нарушить порядок сообщений
• Оптимальное количество зависит от throughput, задержек и количества consumers