一、Kafka的特性
kafka中，写入一个partition分区中的数据是一定有顺序的。
kafka中一个消费者消费一个partition的数据，消费者取出数据时，也是有顺序的。
访问Kafka技术专栏，了解更多的技术细节和项目代码。
专栏
Kafka v2.3 快速入门与实践
33.9币
54人已购
二、多线程消费会导致消息乱序
比如说我们建了一个 topic，有三个 partition。生产者在写的时候，其实可以指定一个 key，比如说我们指定了某个订单 id 作为 key，那么这个订单相关的数据，一定会被分发到同一个 partition 中去，而且这个 partition 中的数据一定是有顺序的。
消费者从 partition 中取出来数据的时候，也一定是有顺序的。到这里，顺序还是 ok 的，没有错乱。
接着，我们在消费者里可能会搞多个线程来并发处理消息。因为如果消费者是单线程消费处理，而处理比较耗时的话，比如处理一条消息耗时几十 ms，那么 1 秒钟只能处理几十条消息，这吞吐量太低了。而多个线程并发跑的话，顺序可能就乱掉了。
专栏
Spring Cloud微服务架构项目实战
33.9币
44人已购
由于消费者消费消息之后，有可能交给很多个线程去处理数据（如下图），这样就导致数据顺序错乱。
需要关注如下几个知识点：
- 写入一个partition中的数据，一定是有顺序的；
- 生产者在写消息的时候，可以指定一个key，比如指定订单的id作为key；则同一个订单相关数据，一定会分发到一个partition中去；
- 消费者从partition中取出数据的时候，一定是有顺序的；
专栏
SkyWalking分布式链路追踪和监控
19.8币
53人已购
三、解决消息的有序性
方案1：
一个 topic，一个 partition，一个 consumer，内部单线程消费，单线程吞吐量太低，一般不会用这个。或者针对前面的方式进行改良，一个topic，多个partition，多个consumer 实例。
这种方式实现起来比较简单快捷，如下图所示，每一个消费者实例负责处理一个partition中的消息。
一个分区Partition不能被同一个消费组（Consumer Group）中多个消费者Consumer消息，这样就保证了Partition中消息消费的有序性。
方案2：
为了保证一个消费者中多个线程去处理时，不会使得消息的顺序被打乱，则可以在消费者中，消息分发至不同的线程时，加一个队列，消费者去做hash分发，将需要放在一起的数据，分发至同一个队列中，最后多个线程从队列中取数据，如下图所示。
写 N 个内存 queue，具有相同 key 的数据都分发到同一个内存 queue；然后对于 N 个线程，每个线程分别消费一个内存 queue 即可，这样就能保证顺序性。
获取更多Elasticsearch设计细节和演示项目源代码，可访问Elasticsearch 7.x 订单中心技术专栏。
专栏
Elasticsearch 7.x订单中心实战
33.9币
109人已购
