开发者社区> 问答> 正文

Kafka 分布式的单位是 Partition。如何保证消息有序?

Kafka 分布式的单位是 Partition。如何保证消息有序?

展开
收起
游客ahv54x37wvm7u 2021-12-07 20:25:29 456 0
1 条回答
写回答
取消 提交回答
  • 同一个 Partition 用一个 write ahead log 组织,所以可以保证 FIFO 的顺序。 不同 Partition 之间不能保证顺序。但是绝大多数用户都可以通过 message key 来定义,因为同一个 key 的 message 可以保证只发送到同一个 Partition。比如说 key 是 user id,table row id 等等,所以同一个 user 或者同一个 record 的消息永远只会发送到同一个 Partition上,保证了同一个 user 或 record 的顺序。 当然,如果你有 key skewness 就有些麻烦,需要特殊处理

    2021-12-07 20:25:41
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
Java Spring Boot开发实战系列课程【第16讲】:Spring Boot 2.0 实战Apache Kafka百万级高并发消息中间件与原理解析 立即下载
MaxCompute技术公开课第四季 之 如何将Kafka数据同步至MaxCompute 立即下载
消息队列kafka介绍 立即下载