Какие знаешь сущности в Kafka

В Kafka есть несколько ключевых сущностей:

1. Топик (Topic) – логический канал для сообщений. Сообщения публикуются в топики и читаются из них. Пример создания топика через CLI:
   bash

   Копировать

   kafka-topics --create --topic my-topic --partitions 3 --replication-factor 2

2. Партиция (Partition) – топик делится на партиции для параллельной обработки. Сообщения в партиции упорядочены.

3. Producer – приложение, публикующее сообщения в топик. Пример на Java:

   java

   Копировать

   producer.send(new ProducerRecord<>("my-topic", "key", "value"));

4. Consumer – приложение, читающее сообщения из топика. Может быть частью Consumer Group.

5. Consumer Group – группа консьюмеров, совместно обрабатывающих топик (каждый консьюмер читает свою партицию).

6. Broker – сервер Kafka, хранящий данные и обслуживающий запросы.

7. ZooKeeper (в версиях до 3.0) – сервис для координации и хранения метаданных кластера.