Re: [I] Consumer 页面中的 Consumer Detail 和 Client 按钮报错 java.lang.NullPointerException: null [rocketmq-dashboard]

[via GitHub]

zergduan commented on issue #295:
URL: 
https://github.com/apache/rocketmq-dashboard/issues/295#issuecomment-2814469574

   猜想可能与以下代码有关：
   
https://github.com/apache/rocketmq-dashboard/blob/a450594ace9fa4d6b6bd33578277d0eb164aa78b/src/main/java/org/apache/rocketmq/dashboard/controller/ConsumerController.java#L119
   
   `    @RequestMapping(value = "/queryTopicByConsumer.query")
       @ResponseBody
       public Object queryConsumerByTopic(@RequestParam String consumerGroup, 
String address) {
           return 
consumerService.queryConsumeStatsListByGroupName(consumerGroup, address);
       }
   
       @RequestMapping(value = "/consumerConnection.query")
       @ResponseBody
       public Object consumerConnection(@RequestParam(required = false) String 
consumerGroup, String address) {
           ConsumerConnection consumerConnection = 
consumerService.getConsumerConnection(consumerGroup, address);
           
consumerConnection.setConnectionSet(ConnectionInfo.buildConnectionInfoHashSet(consumerConnection.getConnectionSet()));
           return consumerConnection;
       }`
   
   
   
   
https://github.com/apache/rocketmq-dashboard/blob/a450594ace9fa4d6b6bd33578277d0eb164aa78b/src/main/java/org/apache/rocketmq/dashboard/service/impl/ConsumerServiceImpl.java
   
       @Override
       public List<TopicConsumerInfo> queryConsumeStatsListByGroupName(String 
groupName, String address) {
           ConsumeStats consumeStats;
           String topic = null;
           try {
               String[] addresses = address.split(",");
               String addr = addresses[0];
               consumeStats = mqAdminExt.examineConsumeStats(addr, groupName, 
null, 3000);
           } catch (Exception e) {
               Throwables.throwIfUnchecked(e);
               throw new RuntimeException(e);
           }
           return toTopicConsumerInfoList(topic, consumeStats, groupName);
       }
   
   
       @Override
       public ConsumerRunningInfo getConsumerRunningInfo(String consumerGroup, 
String clientId, boolean jstack) {
           try {
               return mqAdminExt.getConsumerRunningInfo(consumerGroup, 
clientId, jstack);
           } catch (Exception e) {
               Throwables.throwIfUnchecked(e);
               throw new RuntimeException(e);
           }
       }


-- 
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: commits-unsubscr...@rocketmq.apache.org

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