Каталог статей

1. Комплексный сравнительный анализ Kafka и RabbitMQ

• 1.1 Введение
• 1.2 Комплексный сравнительный анализ Kafka и RabbitMQ
• 1.3 Факторы влияния

2. Основные различия между RabbitMQ и Kafka

• 2.1 Подробное объяснение/основные различия
  • 2.1.1 Цели проектирования и применимые сценарии
  • 2.1.2 Аспекты модели архитектуры
  • 2.1.3 Пропускная способность и производительность
  • 2.1.4 Хранение и постоянство сообщений
  • 2.1.5 Гарантия доставки сообщения
  • 2.1.6 Балансировка нагрузки кластера
  • 2.1.7 Поддержка экосистемы и сообщества
• 2.2 В Интернете мало представлений
  • 2.2.1 Различные способы получения сообщений потребителями
  • 2.2.2 Различные методы обработки после обработки сообщения
  • 2.2.3 Производители отправляют сообщения брокерам разными способами
  • 2.2.4 Масштабируемость и распределенные функции
  • 2.2.5 Кластер (просто разберитесь, осваивать не надо)
• 2.3 Резюме

3. Различия между Kafka, RabbitMQ и RocketMQ

• 3.1 Язык и предпосылки развития
• 3.2 Пропускная способность и производительность
• 3.3 Надежность и отказоустойчивость
• 3.4 Сценарии использования
• 3.5 Другие функции

RabbitMQ и Kafka — две популярные системы обмена сообщениями, которые существенно различаются по нескольким параметрам.

• Во время разработки мы можем столкнуться со следующими ситуациями: Требуется xx, следует ли мне использовать Kafka или RabbitMQ?
• Также часто спрашивают при включении интервью: Кафка、В чем разница между RabbitMQ и почему Project A выбирает Kafka?、И проект B выбирает RabbitMQ?

В общем, нам нужно понимать различия между RabbitMQ и Kafka, для каких сценариев они подходят, а также их соответствующие преимущества и недостатки.

1. Комплексный сравнительный анализ Kafka и RabbitMQ

1.1 Введение

• Kafka — один из лучших проектов Apache с открытым исходным кодом. Он широко используется в сценариях с большими данными. Сообщество в настоящее время активно, и многие организации по всему миру начали использовать Kafka для обмена данными. Kafka использует структуру mq, а у брокера есть концепция разделения частей.

• RabbitMQ — популярная система очередей сообщений с открытым исходным кодом, разработанная на языке erlang. RabbitMQ — это стандартная реализация AMQP (расширенный протокол очереди сообщений, расширенный протокол очереди сообщений). Брокер RabbitMQ состоит из Exchange, Binding и очереди.

1.2 Комплексный сравнительный анализ Kafka и RabbitMQ

поддержка kafka. Потребитель может использовать несколько разделов.,Тот же раздел поддерживает только следующего потребителя той же группы потребителей.,Но поддерживают потребление несколькими группами потребителей.

В проектах компаний, когда объем сообщений, как правило, невелик, блоггеры рекомендуют всем использовать RabbitMQ. Когда количество сообщений увеличивается, вы можете рассмотреть возможность перехода на Kafka, но выбор также должен основываться на внутреннем знакомстве компании с двумя MQ, чтобы избежать невозможности своевременно решать проблемы в MQ.

1.3 Факторы влияния

• Архитектурный дизайн：RabbitMQ Архитектура рассчитана на сложную маршрутизацию. Разработано сообщениями, RabbitMQ Используйте модель push. Производители могут использовать разные правила маршрутизации для отправки сообщений потребителям. Кафка Архитектура специально разработана для сценариев обработки потоков с высокой пропускной способностью в реальном времени и основана на разделах. Кафка Используя модель извлечения, производители публикуют сообщения в темах и разделах, на которые подписываются потребители.
• производительность：Kafka Метод расширения - горизонтальное расширение (горизонтальное расширение). масштабирование), то есть увеличение мощности производительности за счет увеличения количества узлов в кластере. Таким образом, производительность имеет большие преимущества при обработке потоков данных большой емкости и высокой пропускной способности в реальном времени. Она может обрабатывать миллионы событий в секунду и обрабатывать большие объемы данных. КроликMQ Метод расширения – вертикальное расширение (вертикальное расширение). масштабирование), то есть увеличение мощности одного узла за счет увеличения аппаратных ресурсов одного узла, поэтому он становится узким местом в мощности одного узла с точки зрения производительности. так хорошо, как Kafka из.
• задержка сообщения：RabbitMQ Используйте модель push (push модель), то есть коммутатор помещает сообщение в очередь, а затем очередь отправляет сообщение потребителю, что позволяет сократить время ожидания сообщения в очереди и уменьшить задержку Kafka; Используйте модель вытягивания (pull модель), то есть производитель публикует сообщение в теме, а затем потребитель извлекает сообщение из темы. Это может повысить контроль потребителя над сообщением и повысить пропускную способность, но также увеличит задержку. Итак, с точки зрения задержки Kafka Не так хорошо, как RabbitMQ из.
• последовательность сообщений：Kafka Это гарантирует, что сообщения внутри одного раздела упорядочиваются, то есть сохраняются и используются в порядке, отправленном производителем. Однако сообщения между разными разделами не по порядку, то есть нет никакой гарантии, что сообщения между разделами будут обрабатываться в глобальном порядке. RabbitMQ Это гарантирует, что сообщения в одной очереди упорядочиваются, то есть хранятся и потребляются в соответствии с принципом «первым пришел — первым обслужен» (FIFO). Однако сообщения в разных очередях не по порядку, то есть нет гарантии, что сообщения в разных очередях будут обрабатываться в глобальном порядке.
• Механизм аварийного восстановления：Kafka Надежность данных обеспечивается за счет механизма реплик, то есть каждая тема может иметь несколько реплик, распределенных по разным узлам (брокерам). В случае сбоя узла он может автоматически переключаться на другие узлы для продолжения предоставления услуг. RabbitMQ Надежность данных обеспечивается за счет механизма зеркал, то есть каждая очередь может иметь несколько зеркал, распределенных по разным узлам. В случае сбоя узла она может автоматически переключаться на другие узлы для продолжения предоставления услуг.
• Сохранение сообщений：Kafka Сохраняйте данные на диске и поддерживайте сжатие данных и пакетную передачу для повышения производительности и экономии места. Кафка Можетподдерживать TB уровень даже PB Хранение данных уровня и исторические данные могут быть быстро воспроизведены. КроликMQ Данные кэшируются в памяти, а подтверждение сообщения и механизм транзакций используются для повышения надежности и согласованности. КроликMQ Также возможно сохранить данные на диске, но это снизит производительность и пропускную способность. КроликMQ Больше подходит для обработки небольших данных и данных в реальном времени.
• Удаление сообщения：RabbitMQ поддержка механизма подтверждения потребителя (потребитель подтверждение), то есть потребитель отправляет в очередь сигнал подтверждения после получения и обработки сообщения, и очередь удаляет сообщение, обеспечивая таким образом надежную доставку сообщения Kafka; Не Механизм подтверждения потребителей,Вместо этого потребитель добавляет сообщение в файл журнала.,Поддерживайте смещение самостоятельно для записи использованных сообщений.,Тема не будет удалять ни одно сообщение.,Файл журнала будет храниться до истечения срока его хранения.,Если не достигнут заданный срок хранения или ограничение размера. Таким образом, потребитель может повторно обработать исторические данные в потоке в любое время в течение заданного периода времени.
• маршрутизация сообщений：RabbitMQ Поддержка Различные типы переключателей, такие как прямые переключатели обмен), обмен темами (тема обмен), разветвление обмен) и т. д., чтобы добиться различной маршрутизации сообщенийистратегия распределения；Kafka Не обеспечивает фильтрацию сообщений, а также классификацию и распределение сообщений по темам и разделам.
• Простота использования：RabbitMQ Установка и настройка Kafka относительно проста. Вам нужно только загрузить установочный пакет и запустить его. Вы также можете управлять состоянием сервера и отслеживать его через командную строку или графический интерфейс; Установка и настройка относительно сложны и требуют использования ZooKeeper сервис для координации состояния кластера, а некоторые параметры необходимо настроить вручную, чтобы оптимизировать производительность и надежность. Поэтому в Простоте использованияначальство RabbitMQ проще из.

2. Основные различия между RabbitMQ и Kafka

2.1 Подробное объяснение/основные различия

2.1.1 Цели проектирования и применимые сценарии

• RabbitMQ：RabbitMQЭто традиционная система очереди сообщений.,Использование публикации на основе очереди сообщений-Модель подписки
  • цели дизайна：RabbitMQизцели дизайн — это поддержка, которая обеспечивает надежную доставку сообщений и предоставляет несколько протоколов обмена сообщениями.
  • Сценарии применения：Обычно используется дляРабота в режиме реального времени, высокие требования к надежностиизинформация传递начальство
    • Малые и средние проекты, объем сообщений проекта невелик, пропускная способность невысока и чувствительна к задержкам.
    • Устаревшие приложения, например те, которые требуют интеграции или связи с устаревшими или сторонними системами.
    • Сложная маршрутизация, например необходимость распространять или фильтровать сообщения на основе различных правил или условий.
    • Чувствителен к задержкам и предъявляет очень высокие требования к своевременности обработки сообщений потребителями.
• Kafka：KafkaЭто распределенная платформа потоковой передачи событий.,Опубликовано-Модель журнала подписки
  • цели дизайна：Kafkaизцели дизайназаключается в обеспечении высокого Пропускная возможности постоянного хранения,Поддержка источников событий, озера данных и других потребностей в долгосрочном хранении
  • Сценарии применения：В основном используется дляОбработка активных потоковых данных, особенно подходит для сценариев обработки данных с большими объемами данных.。
    • Отслеживайте высокопроизводительные действия, такие как посещения веб-сайтов, журналы приложений, данные датчиков и многое другое.
    • Источник событий: Kafka сохраняет все исторические сообщения и может использоваться для обратного отслеживания событий и аудита.
    • Потоковая обработка, такая как анализ в реальном времени, рекомендации в реальном времени, сигналы тревоги в реальном времени и т. д.
    • Агрегация журналов, например сбор журналов из разных источников, их единообразное хранение и анализ.

2.1.2 Аспекты модели архитектуры

producer,broker,consumer

• RabbitMQ：
  • В центре брокера имеется механизм подтверждения сообщения (механизм подтверждения здесь относится к моменту, когда клиент потребляет сообщение).
  • Режим взаимодействия между брокером и потребителем: RabbitMQ использует метод push
• kafka：
  • Ориентированный на потребителя механизм подтверждения без сообщений (под механизмом подтверждения здесь подразумевается, когда клиент потребляет сообщения)
  • Режим взаимодействия между брокером и потребителем: RabbitMQ использует метод pull

И kafka, и RabbitMQ имеют механизмы подтверждения, отправляемые брокеру.

2.1.3 Пропускная способность и производительность

• RabbitMQ: надежная доставка сообщений подтверждения, транзакций подтверждения, нет поддерживается Пакетная операция,В зависимости от требований к надежности хранения хранилище может использовать память или жесткий диск.,Низкая пропускная способность,Узкое место производительности может быть ограничено одной очередью при обработке большого количества сообщений. Если требуется настойчивость,Будет использоваться хранилище в режиме реального времени.
• kafka: внутренняя пакетная обработка сообщений,Хранение и извлечение данных представляют собой последовательные пакетные операции на локальном диске.,Высокая эффективность обработки сообщений,Высокая пропускная способность,Это связано с его распределенной архитектурой, механизмом секционирования, пакетной обработкой и другими технологиями. Постоянное хранилище по расписанию, постоянное хранилище не в режиме реального времени

2.1.4 Хранение и постоянство сообщений

• RabbitMQ：RabbitMQСообщения обычно сохраняются в течение определенного периода времени.,Затем его удалили, хотя это также подтверждает сохранение сообщения.,Но главным образом для обеспечения надежности сообщения во время доставки.,Не для длительного хранения.
• Kafka：KafkaЧтобы сохранить журнализспособ хранения сообщений,Разрешить сохранение сообщений в течение длительного времени. Такая конструкция делает Kafka очень подходящим для сценариев, требующих длительного хранения и отслеживания сообщений.

2.1.5 Гарантия доставки сообщения

• RabbitMQ：RabbitMQДоступны разные уровнииз Гарантия доставки сообщений, включая как минимум одну доставку, не более одной доставки и ровно одну доставку. Эти механизмы гарантии можно настроить в соответствии с потребностями приложения.
• Kafka：Kafkaобеспечивает мощныйизгарантия сообщения,Обеспечьте постоянство, последовательность и надежность доставки сообщений. Механизм секционирования и репликации Kafka позволяет работать даже в случае сбоя узла.,Это также гарантирует, что сообщения не будут потеряны.

2.1.6 Балансировка нагрузки кластера

• RabbitMQ：само по себе Не обеспечивает балансировку нагрузки, что требует поддержки балансировщика нагрузки。То есть укажите в какой из них сохранятьbrokerКоторый изbroker
• kafka：Используйте Zookeeper для управления брокерами и потребителями в кластере.,Вы можете зарегистрировать темы в Zookeeper.,Через механизм координации Zookeeper,производитель сохраняет информацию о брокере соответствующей темы,Может быть отправлен брокеру случайным образом или путем опроса.,Производители могут указать сегментирование на основе семантики.,Сообщение отправляется на определенный шард брокера. То есть если не указать шардинг,По умолчанию он будет сохранен в осколке мастера.,Затем синхронизируйте с другими осколками

2.1.7 Поддержка экосистемы и сообщества

• RabbitMQ：RabbitMQиметь зрелыйизэкосистема,Включает несколько клиентских библиотек и плагинов.,Подходит для различных языков программированияи Сценарии применения. Он имеет широкую базу пользователей и активное сообщество.
• Kafka：Kafkaтакже имеет огромноеизэкосистема,Особенно подходит для крупномасштабной обработки данных и управления журналами. Kafka также является частью Apache Software Foundation.,Поддерживается обширным сообществом поддержки.

2.2 В Интернете мало представлений

2.2.1 Различные способы получения сообщений потребителями

• RabbitMQ: при использовании метода push, когда сообщение достигает очереди, оно будет отправлено потребителю.
• kafka: при использовании метода pull, когда сообщение попадает в очередь, потребителю необходимо вручную извлечь сообщение из очереди.

2.2.2 Различные методы обработки после обработки сообщения

• RabbitMQ: сообщения, подтвержденные для использования потребителем, будут удалены с диска.
• Кафка: сообщение потребляется, но все еще сохраняется на диске.

2.2.3 Производители отправляют сообщения брокерам разными способами

• RabbitMQ: При работе в качестве главного-подчиненного кластера тот, к кому подключается производитель, отправляет сообщения на соответствующую машину, а другие машины хранят только метаданные. Когда потребитель подключается, ему нужно только подключиться к любому серверу в любом кластере. При получении данных он может связаться с сервером, который фактически хранит сообщения очереди, через метаданные и маршрутизацию.
• Кафка: Когда производитель отправляет сообщение, оно должно быть отправлено на машину, на которой находится главный осколок. Чтобы реализовать эту функцию, когда Kafka подключается к кластеру, при условии, что он подключается к любому одному или нескольким серверам, он может знать ситуацию всего кластера, которая включает IP-адреса всех компьютеров в кластере и информацию о сегментировании. .

2.2.4 Масштабируемость и распределенные функции

• RabbitMQ：RabbitMQМожет Горизонтальное масштабирование через кластеры,но в некоторых случаях,Горизонтальное масштабирование может быть недостаточно гибким. Он поддерживает несколько типов переключателей и вариантов соединения.,Позволяет доставлять сообщения по нескольким путям маршрутизации.
• Kafka：KafkaОн естественным образом распространяетсяиз,Легко масштабируется по горизонтали. Он может легко добавлять новые узлы при увеличении нагрузки.,И одновременно работают несколько производителей и потребителей. Механизм секционирования Kafka позволяет равномерно распределять сообщения по нескольким узлам.,Тем самым улучшая общую производительность системы.

2.2.5 Кластер (просто разберитесь, осваивать не надо)

• RabbitMQ
  • Инициатор синхронизации очереди（Rabbitиспользоватьиз Зеркальный кластер,Кластер «главный-подчиненный» не по умолчанию): при синхронизации очереди зеркала.,Инициируется из основной очереди в зеркальную очередь
  • Ограничения синхронизации реплик：очередь реплик Может Далеко от основной очереди
  • Влияние синхронизации реплик на производительность（Rabbitиспользоватьиз Зеркальный кластер,Кластер «главный-подчиненный» не по умолчанию): при присоединении нового узла.,если ha-sync-mode=manual,Зеркало не будет вручную синхронизировано с новым узлом. Если ha-sync-mode=автоматический,Он будет автоматически синхронизирован с новым узлом. При синхронизации нового узла,Главный узел больше не будет получать сообщения от производителя.,Он не будет доставлять сообщения потребителям.,Это состояние остановки мира. Если на складе слишком много сообщений,Это приведет к истечению времени ожидания запросов производителя и потребителя.,Эту проблему можно решить, установив правила повтора.
• Kafka
  • Инициатор синхронизации очереди（Rabbitиспользоватьиз Зеркальный кластер,Кластер «главный-подчиненный» не по умолчанию): при синхронизации реплик.,Шард-реплика инициирует синхронизацию с основным шардом.
  • Ограничения синхронизации реплик：Осколки-копии могут только отставатьreplica.lag.time.max.msизво времени（ISR）,Если оно превышает это время,Осколок реплики будет удален.
  • Влияние синхронизации реплик на производительность（Rabbitиспользоватьиз Зеркальный кластер,Кластер «главный-подчиненный» не по умолчанию): присоединение новых узлов,Будет активно извлекать данные из основного раздела,Ожидание завершения извлечения данных (за исключением незафиксированных,Включайте только все отправленные данные) перед добавлением узла в кластер.

2.3 Резюме

RabbitMQиKafkaсуществоватьцели дизайн, хранение сообщений, пропускная способность, масштабируемость, Гарантия доставки Существуют существенные различия в таких аспектах, как сообщения и экосистемы. Какую систему выбрать, зависит от конкретного Сценария. примененияинуждаться。если необходимоДоставка данных в реальном времени, низкая задержка и простотаизмодель очереди,RabbitMQможет быть более подходящим；Если обработаноБольшие потоки событий, необходимость постоянства и высокая пропускная способность,И надеемся построить крупномасштабные распределенные системы.,Тогда Кафка может быть более подходящим.

• Rabbit отказывается от пропускной способности ради большей гибкости и информационной безопасности
• Кафка выбрал скорость и отказался от некоторой безопасности ради большей пропускной способности.

Фактический выбор сценария: в реальных производственных приложениях,обычноИспользуйте kafka в качестве конвейера данных для передачи сообщений и RabbitMQ в качестве конвейера передачи данных для данных транзакций.,Основным компромиссным фактором является вероятность потери данных RabbitMQ часто используется в финансовых сценариях;,Иметь высокую строгость,Потеря данных менее вероятна,У коллег более высокая производительность в реальном времени, тогда как преимущество Kafka в основном выражается в пропускной способности;,Хотя потерю данных можно предотвратить с помощью стратегий,Но с строгой точки зрения,Не так хорошо, как RabbitMQ, и потому что Kafka гарантирует, что каждое сообщение будет доставлено хотя бы один раз;,Существует небольшая вероятность того, что данные будут отправлены повторно.

В проектах компании, когда объем сообщений обычно невелик, рекомендуется использовать RabbitMQ. Когда количество сообщений увеличивается, вы можете рассмотреть возможность перехода на Kafka, но выбор также должен основываться на внутреннем знакомстве компании с двумя MQ, чтобы избежать невозможности своевременно решать проблемы в MQ.

3. Различия между Kafka, RabbitMQ и RocketMQ

Kafka, RabbitMQ и RocketMQ в настоящее время широко используются в системах очередей сообщений. Они имеют некоторые очевидные различия в языке, пропускной способности, надежности, сценариях использования и т. д. Основные различия между этими тремя будут подробно сравниваться ниже:

3.1 Язык и предпосылки развития

• Kafka：использоватьScalaразвитие языка,Первоначально разработано и имеет открытый исходный код LinkedIn.,Позже стал частью Apache Software Foundation. Kafka в основном используется для обработки активных потоковых данных.,Особенно подходит дляВысокопроизводительная потоковая передача данных в реальном времени и сценарии потоковой передачи。
• RabbitMQ：Зависит отErlangразвитие языка,Erlang — язык программирования с высокой степенью параллелизма.,делатьRabbitMQОчень подходит дляРабота в режиме реального времени, высокие требования к надежностиизинформация传递начальство。
• RocketMQ：использоватьJavaразвитие языка,Открытый исходный код Alibaba.,Это основной компонент программного обеспечения распределенного обмена сообщениями Alibaba. RocketMQ имеет высокую пропускную способность и стабильность.,Применимо кМасштабная обработка данных и сценарии с высокой пропускной способностью。

3.2 Пропускная способность и производительность

• Kafka：Иметь чрезвычайно высокийиз Пропускная способности низкая задержка,Одна машина можетподдерживать Миллионы сообщений/Второйизвычислительная мощность。Это связано с егоZero Механизм копирования, последовательное чтение и запись диска, механизм пакетной обработки, механизм разделов и другие меры оптимизации.
• RabbitMQ：иKafkaиRocketMQпо сравнению с,RabbitMQиз Пропускная способностьотносительно низкий。это больше Применимо к Обработка менее срочная или менее быстраяизинформация。
• RocketMQ：ХотяRocketMQиз Пропускная способность тоже очень высока,Но он все же немного уступает Кафке. RocketMQ поддерживает простое горизонтальное расширение,Емкость и доступность можно увеличить за счет добавления новых узлов-брокеров.

3.3 Надежность и отказоустойчивость

• Kafka：использовать Распределенная архитектура,поддерживать механизм копирования,Это гарантирует, что сообщения не потеряются при отправке.,А надежность сообщения может быть гарантирована за счет множества копий. Kafka поддерживает синхронизацию и асинхронные методы репликации двух сообщений.,Однако асинхронная репликация может привести к потере данных.
• RabbitMQ：имеет очень высокийизнадежность,Поддержка Множественные механизмы подтверждения сообщений,Например, подтверждение производителя, подтверждение потребителя и т. д.,Это гарантирует, что сообщения не потеряются. RabbitMQ также поддерживает транзакции,Однако использование транзакций может привести к блокировке.
• RocketMQ：такой жеиспользовать Распределенная архитектура,Поддержка Синхронная чистка диска и Асинхронная чистка диска,И синхронная репликация и асинхронная репликация. Синхронная очистка диска RocketMQ имеет более высокую надежность для одной машины, чем Kafka.,Никакие данные не будут потеряны из-за сбоя операционной системы.

3.4 Сценарии использования

• Kafka：Широко используется при сборе журналов、обработка данных в реальном времени、Сценарии, такие как системы обмена сообщениями и потоковая обработка.。Kafkaизвысокий Пропускная способности низкая задержка Характеристики делают его идеальным для обработки крупномасштабных потоков данных.изидеальный выбор。
• RabbitMQ：Применимо к Различные очереди асинхронных задач,Например, отправка электронной почты, отправка текстовых сообщений, перекодирование изображений и видео и т. д. RabbitMQ также предлагает расширенную модель обмена сообщениями.,Такие как RPC, запрос-ответ и подтверждение потребителя и т. д.,Подходит для приложений корпоративного уровня.
• RocketMQ：Применимо к大规模информация传输и Обработать сцену,Например, заказы на платформе электронной коммерции, новости о запасах и т. д. RocketMQ также предоставляет расширенные функции, такие как сообщения распределенных транзакций и последовательные сообщения.,Применимо квернопоследовательность сообщенийи Сценарии с высокими транзакционными требованиями.

3.5 Другие функции

• Kafka：поддерживатьнесколько разделов、несколько продюсеров、несколько потребителей,Модель на основе подписки,поддерживают публикацию-подписку и одноранговое общение. Кафка также поддерживает Сохранение сообщения могут поддерживать дни или даже месяцы хранения данных.
• RabbitMQ：поддерживать Несколько протоколов обмена сообщениями,Включая AMQP, STOMP, MQTT и т. д.,Может удовлетворить различные потребности приложений. Конфигурация и управление RabbitMQ относительно просты.,Легко начать.
• RocketMQ：提供了易ВиспользоватьизAPI,поддерживают несколько языков программирования. RocketMQ также поддерживает функции запроса сообщений и возврата.,Помогает обнаружить проблемы с потерей сообщений и повторно использовать исторические сообщения.

Подводя итог, можно сказать, что Kafka, RabbitMQ и RocketMQ имеют свои преимущества с точки зрения языка, пропускной способности, надежности, сценариев использования и т. д. Какую систему очередей сообщений выбрать, зависит от конкретного сценария приложения и требований.

ссылка Сравнение Kafka и RabbitMQ (супер подробное сравнение с практической точки зрения)、Разница между RabbitMQ и kafka (подробная версия)、Когда использовать Kafka вместо RabbitMQ