单分区Kafka为何出现消息乱序问题？

正常来说，Kafka单分区内的消息是严格按照生产者发送顺序存储并被消费的，出现乱序大概率是生产、消费环节的配置或逻辑问题，常见原因如下：

• 生产者异步发送未保证顺序性
  如果你用KafkaJS同时发起多个异步发送请求（比如用Promise.all批量发送），哪怕目标是同一个分区，Broker处理这些请求的顺序不一定和你发送的顺序一致。尤其是网络存在波动时，晚发的请求可能先到达Broker并被持久化，最终导致分区内消息顺序和发送顺序不符。

• 生产者重试机制触发乱序
  当生产者配置了retries > 0时，如果某条消息发送失败触发重试，而后续的消息已经成功写入分区，这条重试的消息就会排在后面。比如：消息1发送失败，消息2发送成功，之后消息1重试成功，此时分区内的顺序就变成了消息2、消息1，直接导致乱序。如果没开启幂等性（enable.idempotence=true），这种情况会更普遍。

• 消费者端异步处理导致的感知乱序
  有时候消息在Broker里的顺序是对的，但消费者的处理逻辑让你觉得乱序。比如消费者按顺序拿到消息后，用异步任务（比如Promise、回调函数）处理，不同消息的处理耗时不一样——消息1处理需要10秒，消息2只需要1秒，虽然消费者是按顺序接收的，但业务层面会看到消息2先处理完成，误以为消息乱序。

• 生产者acks配置不合理
  如果acks设置为0（不需要Broker确认）或1（只需要主节点确认），当Broker主节点故障切换时可能出现乱序。比如主节点收到消息1还没同步给从节点就挂了，消息2成功发送到新选举的主节点，之后消息1重试成功，此时消息1就会排在消息2后面。

• Broker端极端异常场景
  比如Broker重启时日志恢复出现异常，或者log.flush.interval.ms设置过大导致日志刷写延迟，在极端情况下可能破坏单分区内的消息顺序，但这种情况非常少见。

内容的提问来源于stack exchange，提问作者Caleb Koch