- tocdepth
2
Принцип работы
Кластеры Kafka® состоят из одного или нескольких хостов — брокеров. При создании кластера можно выбрать необходимое количество брокеров. Если один из брокеров выходит из строя, другие берут на себя его работу.
Запись и чтение данных в Kafka® происходит в форме сообщений, которые также называют «событиями» или «записями». Сообщения поступают от одних приложений-клиентов, хранятся в Kafka® и читаются другими приложениями-клиентами. У сообщения есть ключ (key), значение (value), временная метка (timestamp) и опциональные заголовки метаданных.
Сообщения организованно хранятся в топиках. Топик можно сравнить с папкой в файловой системе, а сообщения — с файлами в этой папке.
Приложения-клиенты — поставщики и потребители — подключаются к топикам для записи и чтения сообщений. Поставщики публикуют сообщения в Kafka®, а потребители подписываются на эти сообщения — читают и обрабатывают их. Особенностью Kafka® является то, что поставщики и потребители полностью разделены и независимы друг от друга.
для Dev & Test