You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2020/04/21 01:08:59 UTC

[GitHub] [rocketmq] DandelionJR opened a new issue #1952: golang客户端消费者订阅时写的模式和页面客户端上显示的不一致

DandelionJR opened a new issue #1952:
URL: https://github.com/apache/rocketmq/issues/1952


   我在测试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:
users@infra.apache.org

[GitHub] [rocketmq] DandelionJR commented on issue #1952: golang客户端消费者订阅时写的模式和页面客户端上显示的不一致

Posted by GitBox <gi...@apache.org>.
DandelionJR commented on issue #1952:
URL: https://github.com/apache/rocketmq/issues/1952#issuecomment-616897163


   ok, thanks


----------------------------------------------------------------
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:
users@infra.apache.org

[GitHub] [rocketmq] coder-zzzz commented on issue #1952: golang客户端消费者订阅时写的模式和页面客户端上显示的不一致

Posted by GitBox <gi...@apache.org>.
coder-zzzz commented on issue #1952:
URL: https://github.com/apache/rocketmq/issues/1952#issuecomment-616895644


   You should open an issue in https://github.com/apache/rocketmq-client-go. 
   Not here


----------------------------------------------------------------
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:
users@infra.apache.org