Apache Kafka

1.

Apache Kafka

2.

Очередь (англ. queue) — это структура данных, добавление и удаление элементов в
которой происходит путём операций push и pop соответственно.
Притом первым из очереди удаляется элемент, который был помещен туда первым, то
есть в очереди реализуется принцип «первым вошел — первым вышел»
У очереди имеется голова (англ. head) и хвост (англ. tail). Когда элемент ставится в
очередь, он занимает место в её хвосте. Из очереди всегда выводится элемент, который
находится в ее голове.

3.

4.

• Издатели (publisher) отправляет сообщения на exchange’и (обменники)
• Exchange’и отправляют сообщения в очереди и в другие exchange’и
• RabbitMQ отправляет подтверждения писателям при получении сообщения
• Потребители (consumers) поддерживают постоянные TCP-соединения с RabbitMQ и
объявляют, какую очередь(-и) они получают
• RabbitMQ проталкивает (push) сообщения потребителям
• Потребители отправляют подтверждения успеха/ошибки
• После успешного получения, сообщения удаляются из очередей

5.

6.

7.

8.

9.

kafka-topics.sh
Ключи:

10.

11.

12.

Спасибо за внимание