东莞塘厦做网站磁力宝

Kafka 生产者消息顺序性保障方案

1. 核心实现原理

消息顺序性保障公式：
同一 Key → 同一 Partition → 严格顺序写入

2. 关键配置参数

Properties props = new Properties();
props.put("acks", "all"); // 确保消息持久化
props.put("max.in.flight.requests.per.connection", 1); // 禁止消息乱序
props.put("retries", Integer.MAX_VALUE); // 无限重试
props.put("enable.idempotence", true); // 启用幂等

3. 分区路由策略

// 使用订单ID作为分区键保证顺序性
ProducerRecord<String, String> record = new ProducerRecord<>("order_events", order.getOrderId(), // 关键分区键order.toJSON()
);
producer.send(record);

4. 消费者端保障

props.put("isolation.level", "read_committed"); // 只消费已提交消息
props.put("max.poll.records", 1); // 单次拉取单条记录（严格顺序场景）

5. 注意事项

1. 分区数量限制：消费者线程数 ≤ Partition数量
2. Key设计原则：业务主键（如：订单ID、用户ID）
3. 异步发送禁用：producer.send(record).get() 同步发送
4. 硬件保障：SSD存储+万兆网络避免写入瓶颈

6. 顺序性验证方案

# 查看指定key的消息分布
bin/kafka-run-class.sh kafka.tools.GetOffsetShell \
--broker-list localhost:9092 \
--topic order_events \
--time -1 | grep "特定订单ID哈希值"