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副本机制