分布式消息服務Kafka版與分布式消息服務RocketMQ版的功能區(qū)別：
|
功能項
|
分布式消息服務Kafka版
|
分布式消息服務RocketMQ版
|
|---|---|---|
消費模式 |
客戶端主動拉取 |
支持客戶端主動拉取和服務端推送兩種方式 |
優(yōu)先級隊列 |
不支持 |
|
延遲隊列 |
不支持 |
支持 |
死信隊列 |
不支持 |
支持 |
消息重試 |
不支持 |
支持 |
廣播消費 |
支持 |
支持 |
消息回溯 |
支持 Kafka支持按照offset和timestamp兩種維度進行消息回溯 |
支持 |
消息堆積 |
支持 |
支持 |
持久化 |
支持 |
支持 |
消息追蹤 |
不支持 |
支持 |
消息過濾 |
支持 |
支持 |
多租戶 |
支持 |
支持 |
多協議支持 |
只支持Kafka自定義協議 |
兼容RocketMQ協議 |
跨語言支持 |
采用Scala和Java編寫，支持多種語言的客戶端 |
支持多語言的客戶端 |
流量控制 |
支持client、user和Topic級別，通過主動設置可將流控作用于生產者或消費者 |
RocketMQ 5.x支持基于實例規(guī)格的流量控制。 |
消息順序性 |
支持單分區(qū)（partition）級別的順序性 |
單隊列（queue）內有序 |
安全機制 |
支持SSL、SASL身份認證和讀寫權限控制 |
支持SSL認證 |
事務性消息 |
支持 |
支持 |
分布式消息服務Kafka版與分布式消息服務RocketMQ版的應用場景區(qū)別：
分布式消息服務Kafka版，兼容開源Kafka，采用拉?。≒ull）方式消費消息，吞吐量相對更高，適用于海量數據收集與傳遞場景，例如日志采集和集中分析。
分布式消息服RocketMQ版，兼容開源RocketMQ，基于Java語言開發(fā)，適用于對數據可靠性、數據實時性要求高，Topic數量非常多的場景，如訂單、交易、充值、流計算、消息推送、日志流式處理、binlog分發(fā)等。
分布式消息服務Kafka版與分布式消息服務RocketMQ版的性能區(qū)別：
分布式消息服務Kafka版的單機QPS能夠達到百萬級別。
分布式消息服RocketMQ版的單broker QPS在萬級別。
分布式消息服務Kafka版與分布式消息服務RocketMQ版的數據可靠性區(qū)別：
分布式消息服務Kafka版采用多副本機制，數據可靠性較高。
分布式消息服RocketMQ版采用3副本機制，數據可靠性較高。 RocketMQ采用Raft一致性協議，數據一致性高于Kafka。
分布式消息服務Kafka版與分布式消息服務RocketMQ版的服務可用性區(qū)別：
分布式消息服務Kafka版采用集群部署，分區(qū)與多副本的設計，使得單代理宕機對服務無影響，且支持消息容量的線性提升。
分布式消息服RocketMQ版采用Raft一致性協議，單臺機器宕機會重新選主，可用性高。
了解分布式消息服務Kafka版必看文檔
了解分布式消息服務RocketMQ版必看文檔
-
RocketMQ功能總覽
-
RocketMQ 產品介紹
-
RocketMQ 快速入門
本手冊介紹RocketMQ入門的基本流程，主要包括創(chuàng)建和連接RocketMQ實例的操作。
本手冊介紹RocketMQ入門的基本流程，主要包括創(chuàng)建和連接RocketMQ實例的操作。