Что такое топики и как они используются в Kafka?

Question

Топик — логическая категория сообщений в Kafka. Продюсеры отправляют сообщения в топики, а консюмеры читают из топиков, при этом данные внутри топика разбиваются на партиции для масштабирования и параллелизма.

YeaHub · Accepted Answer

Определение топика:- Топик — имя потока событий (например, user-signups).- Все сообщения с одинаковым ключом в одном топике попадают в одну партицию. Партиции:- Топик разбивается на несколько партиций для параллельной обработки.- Каждая партиция — упорядоченный лог. Производитель и потребитель:- Продюсер отправляет записи: producer.send("topic", key, value).- Консюмер подписывается: consumer.subscribe(["topic"]), затем читает блоками. Распределение нагрузки:- Консюмер-группа читает из партиций параллельно.- Каждая партиция обслуживается одним консюмером в группе. Когда использовать:- Организация потоков событий по тематике.- Горизонтальное масштабирование обработки.