Kafka — распределённый журнал: сообщения хранятся заданное время независимо от чтения, потребители сами двигают offset и могут перечитать. RabbitMQ — классический брокер очередей: сообщение удаляется после подтверждения, гибкая маршрутизация через exchange.
А ещё RabbitMQ Streams и Kafka Queues (KIP-932) сближают модели
Так подсказку видит пользователь sotto на живом собеседовании — за пару секунд, пока вы думаете вслух.
Модель Kafka. Топик разбит на партиции — упорядоченные журналы на диске. Производитель дописывает в конец, потребители читают с позиции (offset), которую сами хранят и фиксируют. Сообщения не удаляются после чтения, а живут по политике хранения (время или размер) — поэтому разные группы потребителей читают независимо, а любую можно перемотать и перечитать историю. Параллелизм — число партиций. Порядок — внутри партиции.
Модель RabbitMQ. Издатель публикует в exchange, который по правилам (direct, topic, fanout, headers) раскладывает сообщения по очередям. Потребитель получает сообщение, обрабатывает и подтверждает (ack) — после этого оно удаляется. Брокер следит за каждым сообщением: повтор неподтверждённых, DLX, TTL, приоритеты.
Следствия:
| Kafka | RabbitMQ | |
|---|---|---|
| хранение | журнал, по времени | до подтверждения |
| перечитывание | да | нет (кроме Streams) |
| маршрутизация | по топикам и ключу | гибкая, exchange и bindings |
| порядок | в партиции | в очереди при одном потребителе |
| пропускная способность | сотни тысяч–миллионы в секунду | десятки тысяч |
| состояние потребителя | offset у клиента | у брокера на сообщение |
Модель exchange/binding/queue, ack/nack и publisher confirms, prefetch, DLQ через DLX, отложенные сообщения, SQS Standard vs FIFO и visibility timeout.
sotto слышит вопрос интервьюера и показывает короткий ответ и план, как в блоке «Коротко». Оставьте контакт — пришлём доступ и промокод.
sotto