На что делится Kafka Topic

Kafka Topic делится на партиции (partitions) — логические части, которые распределяют нагрузку и обеспечивают параллельную обработку сообщений.

Особенности:

• Каждая партиция упорядочена (сообщения внутри неё идут строго по порядку).
• Партиции распределяются между брокерами Kafka для отказоустойчивости.
• Сообщения в партиции назначаются по ключу (key) или рандомно (если key=null).

Пример:

// Создание топика с 3 партициями  
Properties props = new Properties();  
props.put("bootstrap.servers", "localhost:9092");  
AdminClient admin = AdminClient.create(props);  

NewTopic topic = new NewTopic("my_topic", 3, (short) 1);  
admin.createTopics(Collections.singleton(topic));  

Чем больше партиций — тем выше параллелизм, но избыток может ухудшить производительность.