MQClientInstance 中为什么 consumerTable 的key设置成 group

提问22.png

当我给两个 topic设置相同 的group时 ,抛异常 Caused by The consumer group[group] has been created before, specify another name please 而我的本意不是要使用同一个consumer ,消费两个topic. 单纯就是写错group了。

想咨询一下 设计的想法,为什么 MQClientInstance 中的consumerTable 的key是group, 而不是 topic+group. 这样就能区分 不同的topic + 相同的group了,对应的是两个不同的consumer。

原提问者GitHub用户gongchangyou

展开
收起
芬奇福贵 2023-05-26 10:32:18 124 分享 版权
1 条回答
写回答
取消 提交回答
  • 事实上,一个消费组的所有实例应该订阅相同的Topic,如果不同实例订阅的Topic不相同,服务端保存的订阅关系会被频繁修改,会导致消费混乱,甚至消息丢失。正确的方法应该是使用不同的消费组去订阅不同的Topic。可以参考下https://help.aliyun.com/document_detail/43523.html。

    原回答者GitHub用户cserwen

    2023-05-26 16:48:55
    赞同 展开评论
问答地址:

阿里云拥有国内全面的云原生产品技术以及大规模的云原生应用实践,通过全面容器化、核心技术互联网化、应用 Serverless 化三大范式,助力制造业企业高效上云,实现系统稳定、应用敏捷智能。拥抱云原生,让创新无处不在。

还有其他疑问?
咨询AI助理