rocketmq和kafka的区别

介绍

---

区别

数据可靠性

• RocketMQ支持异步实时刷盘，同步刷盘，同步Replication，异步Replication。
• kafka使用异步刷盘模式，异步Replication。

性能对比

• kafka单机TPS约在百万条/秒，消息大小10个字节。
• RocketMQ单机写入TPS单实例约7万条/秒，单机部署3个broker，最高可以跑到12万条/秒，消息大小10个字节。

kafka主要是由于Producer端将多个小消息合并，批量发向Broker。

单机支持的队列数

• kafka单机超过64个队列/分区，Load会发生明显的飙高现象，队列越多，load越高，发送消息响应时间边长。
• RocketMQ单机最多支持5万个队列，load不会发生明显变化。

消息投递实时性

• kafka使用端轮询方式，实时性取决于轮询时间间隔。
• RocketMQ使用长轮询，同Push方式实时性一致，消息的投递延时通常在几个毫秒。

消费失败重试

• kafka消费失败不支持重试。
• RocketMQ消费失败支持定时重试，每次重试时间间隔依次增大。

严格的消息顺序

• kafka支持消息顺序，但是一台Broker宕机后，就会产生消息乱序。
• RocketMQ支持严格的消息顺序，在顺序消息场景下，一台Broker宕机，发送消息会失败，但不会乱序。

定时消息

• kafka不支持定时消息
• RocketMQ支持定时消息
  • 支持定时level，以及指定毫秒级别的延时时间

分布式事务消息

• kafka不支持分布式事务消息
• RocketMQ支持分布式事务消息，采用半消息实现

消息查询

• kafka不支持消息查询
• RocketMQ支持根据Message Id查询消息，也支持根据消息内容查询消息

消息回溯

• kafka理论上可以按照Offset来回溯消息
• rocketMQ支持按照时间来回溯消息，精度毫秒，例如从一天之前的某时某分某秒开始重新消费消息

消费并行度

• kafka消费的并行度依赖topic配置的分区数，消费并行度和分区数一致。
• RocketMQ消费并行度分两种情况
  • 顺序消费方式并行度同Kafka完全一致
  • 乱序方式并行度取决于Consumer的线程数，如Topic配置10个队列，10台机器消费，每台机器100个线程，那么并行度为1000。

Broker端消息过滤

• kafka不支持broker端消息过滤
• RocketMQ支持两种消息过滤方式
  • 根据tag来过滤，相当于子topic
  • 向服务器上传一段Java代码，可以对消息做任意形式的过滤，甚至可以做Message Body的过滤拆分。

使用区别

• kafka在日志，大数据领域比较成熟
• RocketMQ多用于削峰填谷，多用于业务领域。