1 个回答
造成MQ消息队列消息乱序的主要原因有:
1、分区机制的问题
1、分区机制的问题
如Kafka中,一个Topic可以有多个Partition。如果生产者没有按照Key进行分区控制,不同的消息可能被分配到不同的Partition中,而每个Partition独立消费,就会出现乱序。
2、多线程消费的问题在Kafka或RocketMQ中,如果开启多线程消费,不同线程可能处理不同Offset的消息,从而导致乱序。
3、网络重传和ack机制如果消费者在处理完消息后未及时提交Offset,Broker会重新投递该消息,造成重复消费和乱序。
发布于:2个月前 (05-13) IP属地:
我来回答
您需要 登录 后回答此问题!