Kafka如何保证消息的顺序性

Posted windpoplar

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Kafka如何保证消息的顺序性相关的知识,希望对你有一定的参考价值。

1. 问题

比如说我们建了一个 topic,有三个 partition。生产者在写的时候,其实可以指定一个 key,比如说我们指定了某个订单 id 作为 key,那么这个订单相关的数据,一定会被分发到同一个 partition 中去,而且这个 partition 中的数据一定是有顺序的。
消费者从 partition 中取出来数据的时候,也一定是有顺序的。到这里,顺序还是 ok 的,没有错乱。接着,我们在消费者里可能会搞多个线程来并发处理消息。因为如果消费者是单线程消费处理,而处理比较耗时的话,比如处理一条消息耗时几十 ms,那么 1 秒钟只能处理几十条消息,这吞吐量太低了。而多个线程并发跑的话,顺序可能就乱掉了。

技术图片

2. 解决方案

  • 一个 topic,一个 partition,一个 consumer,内部单线程消费,单线程吞吐量太低,一般不会用这个。
  • 写 N 个内存 queue,具有相同 key 的数据都到同一个内存 queue;然后对于 N 个线程,每个线程分别消费一个内存 queue 即可,这样就能保证顺序性

技术图片

 

以上是关于Kafka如何保证消息的顺序性的主要内容,如果未能解决你的问题,请参考以下文章

Kafka如何保证消息的顺序性

Flink消费Kafka如何保证相同标识消息的有序性

kafka如何保证顺序性

2020-12-25:MQ中,如何保证消息的顺序性?

RabbitMQ 如何保证消息顺序 --- 2022-04-03

如何保证MQ的顺序性?比如Kafka