[GitHub] [rocketmq] MatrixHB opened a new issue #3890: ConsumerConnectionSubCommand needs 'brokerAddress' param

[GitBox <gi...@apache.org>]

MatrixHB opened a new issue #3890:
URL: https://github.com/apache/rocketmq/issues/3890


   The command `ConsumerConnectionSubCommand`  is used to query the connection of consumer and brokers, and it randomly selects one of all brokers to view the consumers who maintain the heartbeat with this broker. 
   ```
           String topic = MixAll.getRetryTopic(consumerGroup);
           List<BrokerData> brokers = this.examineTopicRouteInfo(topic).getBrokerDatas();
   // randomly select
           BrokerData brokerData = brokers.get(random.nextInt(brokers.size()));
           String addr = null;
           if (brokerData != null) {
               addr = brokerData.selectBrokerAddr();
               if (StringUtils.isNotBlank(addr)) {
                   result = this.mqClientInstance.getMQClientAPIImpl().getConsumerConnectionList(addr, consumerGroup, timeoutMillis);
               }
           }
   ```
   When one broker encounter network problem or FGC, the `consumertable` maintained locally by the broker does not conform to the reality. When this broker is randomly selected, it is determined that the consumer is "offline".
   
   
   
   In order to more easily locate the broker with problems when facing such problems, the ConsumerConnection command needs to have a more specific '-b' parameter (not available at present).


-- 
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.

To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq] duhenglucky closed issue #3890: ConsumerConnectionSubCommand needs 'brokerAddress' param

[GitBox <gi...@apache.org>]

duhenglucky closed issue #3890:
URL: https://github.com/apache/rocketmq/issues/3890


   


-- 
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.

To unsubscribe, e-mail: dev-unsubscribe@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org