首页  

RocketMQ Kafka 简单比较     所属分类 rocketmq 浏览量 156
RocketMQ Java版的 kafka


适用场景
Kafka适合日志处理 , RocketMQ适合业务处理


架构上的区别
kafka通过zookeeper来进行协调,rocketMq通过自身的namesrv进行协调
kafka 具备选举功能 先选举 KafkaController ,再由KafkaController选出 partition 的 master 和 slave
某个partition的master挂了 , 某个 slave 会升级成 master


rocketMQ 不选举,Master/Slave的角色是固定的 
使用轻量级的NameServer(多台),没有使用ZK(rocketmq没有选举) 
broker: master、slave模式(预先配置好)master挂了不能写,还可以继续读(可以从master和slave读) 


性能
Kafka单机写入 TPS 号称在百万条/秒 , RocketMQ 大约在10万条/秒

可靠性
RocketMQ支持异步/同步刷盘,异步/同步Replication
Kafka使用异步刷盘方式,异步Replication
RocketMQ 支持同步方式 可靠性更高


实时性
均支持pull长轮询

支持的队列数
Kafka单机超过64个队列/分区,消息发送性能严重下降
RocketMQ 单机支持最高5万个队列,性能稳定


消息顺序性
kafka 同一个分区 保证 顺序
RocketMQ支持严格的消息顺序

消费失败重试机制
Kafka消费失败不支持重试
RocketMQ消费失败支持定时重试,每次重试间隔时间顺延。

定时/延时消息
Kafka不支持 ,RocketMQ支持 

消息查询机制
RocketMQ支持根据Message Id查询消息,也支持根据消息内容查询消息

消息回溯
Kafka可以按照Offset来回溯消息
RocketMQ支持按照时间来回溯消息,精度毫秒,例如从一天之前的某时某分某秒开始重新消费消息


Kafka的业务应用场景主要定位于日志传输 ,对于复杂业务支持不够
数据可靠性、数据实时性、消息队列个数



rocketmq要点 rocketmq知识点 kafka知识点 kafka高性能要点 kafka高可用机制简介 kafka知识点整理之概述 kafka副本机制

上一篇     下一篇
mybatis 代码方式创建 SqlSessionFactory

springboot mybatis 多数据源实例

贝尔宾团队角色理论:优秀团队的9种角色

如何手工触发fullgc

mongodb简介

springboot2集成业务指标