首页
学习
活动
专区
工具
TVP
发布
精选内容/技术社群/优惠产品,尽在小程序
立即前往

关于 RocketMQ ClientID 相同引发的消息堆积的问题

其中讲到了: 消息堆积 重复消费自不必说,你 ClientID 都相同了。本篇着重聊聊为什么会消息堆积。 文章中讲到,初始化 Consumer 时,会初始化 Rebalance 的策略。...入参 需要以下四个: ConsumerGroup 消费者组的名字 currentCID 当前消费者的 clientID mqAll 当前 ConsumerGroup 所消费的 Topic 下的所有的 MessageQueue...cidAll 当前 ConsumerGroup 下所有消费者的 ClientID 实际上是将某个 Topic 下的所有 MessageQueue 分配给属于同一个消费者的所有消费者实例,粒度是 By...而我们开篇提到的 Consumer 的 ClientID 相同,会造成什么? 当然是 index 的值相同,进而造成 mod、averageSize、startIndex、range 全部相同。

1.1K30
  • 您找到你想要的搜索结果了吗?
    是的
    没有找到

    Client ID认证「建议收藏」

    Client ID 认证不依赖外部数据源,使用上足够简单轻量,使用该种认证方式时需要开启 emqx_auth_clientid插件,直接在DashBoard中开启即可, 2.哈希方法   Client...ID 认证默认使用 sha256 进行密码哈希加密,可在 etc/plugins/emqx_auth_clientid.conf 中更改:      # etc/plugins/emqx_auth_clientid.conf...1:添加认证数据API 定义: POST api/v4/auth_clientid{ “clientid”: “emqx_c”, “password”: “emqx_p”}     ####添加...clientId和密码#####     POST http://{{hostname}}:{{port}}/api/v4/auth_clientid HTTP/1.1     Content-Type...#############获取指定ClientId详细信息########     GET http://{{hostname}}:{{port}}/api/v4/auth_clientid

    1.1K10
    领券