首页 > 项目 > 当前页面

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

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

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

上一篇：Kafka 是否会弄丢数据？

下一篇：RocketMQ消息发送之广播模式

相关文章

NEW个对象 NEW个对象
JAVA是世界上最好的语言

推荐文章

最新文章