Kafka 与 RabbitMQ 的差异与选择

结论先行

Kafka 是分布式提交日志，适合高吞吐事件流、日志管道、回放和流处理；RabbitMQ 是传统消息代理，适合任务队列、请求响应、复杂路由和低延迟投递。不要把两者都当成“消息队列”随便替换。

核心差异

维度	Kafka	RabbitMQ
模型	分区日志，消费者按 offset 读取	队列 + 交换机 + 绑定
路由	按 topic/partition	direct/topic/fanout/headers
吞吐	很高，适合批量事件	高，但更偏消息投递
保留	按时间/大小保留，可回放	消费后删除，默认不保留
顺序	分区内有序	单队列有序，取决于消费模型
确认	消费者提交 offset	ack/nack + prefetch
生态	Connect、Streams、ksqlDB	管理插件、多语言客户端
典型场景	日志、事件溯源、数据管道	任务队列、RPC、业务消息

怎么选

需要回放历史事件、多个消费者独立消费：Kafka。
需要复杂路由、优先级、延迟队列：RabbitMQ。
高吞吐日志/指标管道：Kafka。
低延迟任务分发、工作队列：RabbitMQ。

注意

kafka-topics --bootstrap-server broker:9092 --describe --topic events
rabbitmqctl list_queues -p /app name messages consumers

Kafka 的顺序只在分区内保证；按 key 分区才能保证同一实体有序。
RabbitMQ 的 ack、prefetch 和持久化配置共同决定是否丢消息。
Kafka 的 retention 会影响磁盘和回放能力；不是“消费即删”。
RabbitMQ 队列堆积会占内存/磁盘；需要 TTL、死信队列和限流。
两者都需要集群、监控和容量规划；不能只看客户端 API 相似。

相关命令

kafka-topics / kcat — Kafka
rabbitmq / rabbitmqctl — RabbitMQ
nats / pulsar — 其他消息系统