RocketMQ 的Rebalance机制，消息重复问题

MickyInvQ

发布于 2023-04-04 09:28:27

3020

发布于 2023-04-04 09:28:27

文章被收录于专栏：InvQ的专栏InvQ的专栏

集群模式下，每个消费者实例会被分配到若干条队列。正因为消费者拿到了明确的队列，所以它们才能针对对应的队列做循环拉取消息的处理，以下是消费者客户端和broker通信的部分代码，可以看到通信的参数里有一个重要的参数，就是queueId

 PullMessageRequestHeader requestHeader = new PullMessageRequestHeader();

本文参与腾讯云自媒体分享计划，分享自作者个人站点/博客。

如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自作者个人站点/博客前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体分享计划，欢迎热爱写作的你一起参与！

登录后参与评论

0 条评论

热度