上云无忧 > 文档中心 > 天翼云分布式消息服务RocketMQ消费者同组Consumer订阅关系一致
分布式消息服务RocketMQ
天翼云分布式消息服务RocketMQ消费者同组Consumer订阅关系一致

文档简介:
RocketMQ 里的一个 Consumer Group 代表一个 Consumer 群组。对于大多数分布式应用来说,一个 Consumer Group 下通常会有多个 Consumer 实例。订阅关系一致指的是同一个 Consumer Group 下所有 Consumer 实例的处理逻辑必须完全一致,一旦订阅关系不一致,消息消费的逻辑就会混乱,甚至导致消息丢失。
*产品来源:中国电信天翼云。免费试用 咨询热线:400-826-7010,为您提供专业的售前咨询,让您快速了解云产品,助您轻松上云! 微信咨询
  免费试用、价格特惠
RocketMQ 里的一个 Consumer Group 代表一个 Consumer 群组。对于大多数分布式应用来说,一个 Consumer Group 下通常会有多个 Consumer 实例。订阅关系一致指的是同一个 Consumer Group 下所有 Consumer 实例的处理逻辑必须完全一致,一旦订阅关系不一致,消息消费的逻辑就会混乱,甚至导致消息丢失。
由于 RocketMQ 的订阅关系主要由 Topic+Tag 共同组成,因此,保持订阅关系一致意味着同一个 Consumer group 下所有的实例需在以下两方面均保持一致:
1)订阅的 Topic 必须一致;
2)订阅的 Topic 中的 Tag 必须一致。
相似文档
  • 使用CTGFactory进行创建实例【强制规范】; Consumer是重量级的实例,每次创建、销毁都会消耗系统资源,建议系统启动的时候创建,系统退出的时候关闭,禁止每次消费消息都创建新的实例【强制规范】。
  • 一个Topic,可以使用多个消费组消费消息,每个消费组将在服务端独立保存进度。 集群消费意味着多个消费者均衡消费Topic的消息,由于经常不同的程序由多个开发者进行研发和调试,如果使用同一个消费组,在调试过程中存在被其他程序消费者消费的可能,因此应该尽量避免多种类型的应用程序使用同一个消费组。
  • 管理员可以通过《运维管理命令手册.docx》,重置消费进度,使用注意事项如下: 消费重置时间是指:消息的生产时间,而不是消息的消费时间。 resetOffsetByTimeOffline 客户端必须离线,重置后启动。 resetOffsetToLatest 客户端必须离线,重置后启动,重置到最新。
  • 不建议高堆积量的消费,为了预防出现高堆积的情况,建议: 边生产边消费,如果消费速度跟不上,增加消费者。 消费者一直在线,不要等生产了一段时间再开启消费者,这样会造成消费的堆积。
  • 在RocketMQ中,队列数直接影响到消费者实例数的上限,同一消费组消费者实例数的上限=队列数,需要集群消费的情况,需考虑队列数的设置。 在RocketMQ中,队列能分布到不同的Broker上,是RocketMQ分布式的基础。
官方微信
联系客服
400-826-7010
7x24小时客服热线
分享
  • QQ好友
  • QQ空间
  • 微信
  • 微博
返回顶部