更新时间:2024-04-07 GMT+08:00

与RocketMQ的差异

表1 功能差异

功能项

RocketMQ

Kafka

优先级队列

不支持

不支持

延迟队列

支持

不支持

死信队列

支持

不支持

消息重试

支持

不支持

消费模式

支持客户端主动拉取和服务端推送两种方式

客户端主动拉取

广播消费

支持

支持

消息回溯

支持

支持。Kafka支持按照offset和timestamp两种维度进行消息回溯。

消息堆积

支持

支持。

持久化

支持

支持

消息追踪

支持

不支持

消息过滤

支持

支持

多租户

支持

不支持

多协议支持

兼容RocketMQ协议

只支持Kafka自定义协议。

跨语言支持

支持多语言的客户端

采用Scala和Java编写,支持多种语言的客户端。

流量控制

待规划

支持client和user级别,通过主动设置可将流控作用于生产者或消费者。

消息顺序性

单队列(queue)内有序

支持单分区(partition)级别的顺序性。

安全机制

支持SSL认证

支持SSL、SASL身份认证和读写权限控制。

事务性消息

支持

支持