Об этом проекте

Apache RocketMQ представляет собой распределенную платформу для обмена сообщениями и потоковой обработки данных, разработанную с акцентом на высокую пропускную способность, минимальные задержки и гарантированную надежность доставки информации. Платформа спроектирована так, чтобы справляться с триллионами сообщений при гибком масштабировании, что делает ее идеальным решением для сложных корпоративных приложений с событийной архитектурой. Ключевые особенности включают поддержку паттернов «издатель/подписчик» (publish/subscribe) и «запрос/ответ» (request/reply), а также реализацию транзакционных сообщений банковского уровня и строгую гарантию порядка их следования (FIFO). Благодаря встроенному механизму отказоустойчивости DLedger, функциям трассировки сообщений и широкой интеграции с экосистемами больших данных, Apache RocketMQ обеспечивает стабильную работу даже в самых требовательных условиях. Платформа поддерживает множество протоколов связи, включая gRPC, MQTT и JMS, предоставляя эффективные модели потребления данных как по запросу (pull), так и через push-уведомления. Развертывание возможно в различных средах: от локальных машин до контейнеров Docker и кластеров Kubernetes с использованием специального оператора RocketMQ Operator. Экосистема проекта включает богатый набор инструментов: административные панели управления, экспортеры метрик для Prometheus, клиенты для популярных языков программирования (Java, Go, Python, C++, Node.js), а также коннекторы для бесшовной интеграции с такими системами, как Flink и Spring Boot.