DandelionJR opened a new issue #471:
URL: https://github.com/apache/rocketmq-client-go/issues/471
我在测试rocketmq时，消费者订阅采用的是BROADCASTING，页面上却显示为CLUSTERING。我在源码中仔细查找，发现写死CLUSTERING，如下所示：
c.consumerMap.Range(func(key, value interface{}) bool { consumer :=
value.(InnerConsumer) cData := consumerData{ GroupName: key.(string), CType:
"PUSH", MessageModel: "CLUSTERING", Where: "CONSUME_FROM_FIRST_OFFSET",
UnitMode: consumer.IsUnitMode(), SubscriptionDatas:
consumer.SubscriptionDataList(), } hbData.ConsumerDatas.Add(cData) return true
})
这段代码在internal.client.go的SendHeartbeatToAllBrokerWithLock中，当我改变MessageModel的值为BROADCASTING时，页面上显示为BROADCASTING，请问这是bug还是我自己测试错误
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
