帮忙么网 > Kafka > 当前页面

Kafka 如何保证消息的顺序性?

2025-01-11 NEW个对象

Consumer ,拉取到消息后,写到 N 个内存 queue,具有相同 key 的数据都到同一个内存 queue 。然后,对于 N 个线程,每个线程分别消费一个内存 queue 即可,这样就能保证顺序性。

1、从服务端拉去消息
2、根据key将消息存到不同的队列
3、开启线程进行消费。

相关文章

  • Kafka 是否会弄丢数据?

    当然会 kafka分为生产者、服务端、消费端

    NEW个对象 2025-01-11

  • RocketMQ消息发送之广播模式

    广播模式:在广播模式下,每条消息都会被推送到集群内所有注册过的客户端,保证消息至少被每台机器消费一次。

    NEW个对象 2025-01-11

  • Kafka 如何保证消息的顺序性?

    Consumer ,拉取到消息后,写到 N 个内存 queue,具有相同 key 的数据都到同一个内存 queue 。然后,对于 N 个线程,每个线程分别消费一个内存 queue 即可,这样就能保证顺序性。

    NEW个对象 2025-01-11

推荐文章