Для чего нужен Kafka Topic

Kafka Topic — это логическая категория или канал, в который продюсеры публикуют сообщения, а консьюмеры подписываются для их чтения.

Основные функции:

• Организация данных по темам (например, orders, logs).
• Поддержка параллельной обработки через партиции (partition).
• Хранение сообщений с настраиваемой политикой retention (время/размер).

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

Properties props = new Properties();
props.put("bootstrap.servers", "localhost:9092");
AdminClient admin = AdminClient.create(props);

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

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

• Сообщения в топике упорядочены только в рамках партиции.
• Поддерживает репликацию для отказоустойчивости.
• Масштабируется горизонтально за счет партиций.