Kafka消息顺序性保证与方案

Kafka顺序性保证：

1. 分区内有序：相同Partition内的消息严格按Producer发送顺序追加，Consumer按顺序消费
2. 跨分区无序：不同Partition之间消息是无序的，因为负载均衡分发到不同分区

方案一：单分区全局有序（牺牲性能）

• Topic只设置1个Partition
• 保证全局有序，但吞吐量和并行度受限（单分区单消费者）
• 适用于低并发但要求严格有序的场景（如银行交易流水）

方案二：相同业务放入同一分区

• 按业务Key指定Partition（如订单ID、用户ID）

// 生产者配置：相同订单ID的消息进入同一分区
props.put(ProducerConfig.PARTITIONER_CLASS_CONFIG, 
          "org.apache.kafka.clients.producer.RoundRobinPartitioner");
// 或代码中指定分区键
ProducerRecord<String, String> record = 
    new ProducerRecord<>("order-topic", orderId, orderJson);

• 同一个订单的消息保证有序，不同订单可并行

方案三：消费者单线程消费

• 即使消息分区内有序，消费者如果多线程处理同一分区仍可能乱序
• 同一分区使用单线程消费，或使用有序线程池（如按Key哈希到同一线程）

业务案例（订单状态流转）：

// 订单状态：待支付 → 已支付 → 已发货 → 已完成
// 使用orderId作为分区Key，保证同一订单的消息有序
// 消费者单线程消费（或按orderId hash到固定线程）
// 使用数据库乐观锁检测状态冲突
UPDATE order SET status = 'PAID' 
WHERE order_id = ? AND status = 'UNPAID'

总结：保证顺序性的核心是同一业务Key进入同一分区 + 同一分区单线程消费。不能同时追求全局严格有序和高吞吐量。