You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by "Jinduoxia666 (via GitHub)" <gi...@apache.org> on 2024/01/06 15:49:46 UTC

[I] [Bug] can not get consumerStatus [rocketmq]

Jinduoxia666 opened a new issue, #7728:
URL: https://github.com/apache/rocketmq/issues/7728

   ### Before Creating the Bug Report
   
   - [X] I found a bug, not just asking a question, which should be created in [GitHub Discussions](https://github.com/apache/rocketmq/discussions).
   
   - [X] I have searched the [GitHub Issues](https://github.com/apache/rocketmq/issues) and [GitHub Discussions](https://github.com/apache/rocketmq/discussions)  of this repository and believe that this is not a duplicate.
   
   - [X] I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ.
   
   
   ### Runtime platform environment
   
   macos sonoma 14.2.1
   
   ### RocketMQ version
   
   5.1.4
   
   ### JDK Version
   
   openjdk 8
   
   ### Describe the Bug
   
   org.apache.rocketmq.client.exception.MQClientException: CODE: 1  DESC: invoke consumer <GID_jdx> <ji...@5vp8vpbzq> Exception: org.apache.rocketmq.remoting.exception.RemotingSendRequestException: send request to <192.168.2.7:58210> failed, org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.invokeSyncImpl(NettyRemotingAbstract.java:496)
   For more information, please visit the url, https://rocketmq.apache.org/docs/bestPractice/06FAQ
   	at org.apache.rocketmq.client.impl.MQClientAPIImpl.getConsumerRunningInfo(MQClientAPIImpl.java:2618)
   	at org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl.getConsumerRunningInfo(DefaultMQAdminExtImpl.java:1312)
   	at org.apache.rocketmq.tools.admin.DefaultMQAdminExtImpl.getConsumerRunningInfo(DefaultMQAdminExtImpl.java:1299)
   	at org.apache.rocketmq.tools.admin.DefaultMQAdminExt.getConsumerRunningInfo(DefaultMQAdminExt.java:580)
   	at org.apache.rocketmq.tools.command.consumer.ConsumerStatusSubCommand.execute(ConsumerStatusSubCommand.java:103)
   	at org.apache.rocketmq.tools.command.MQAdminStartup.main0(MQAdminStartup.java:165)
   	at org.apache.rocketmq.tools.command.MQAdminStartup.main(MQAdminStartup.java:115)
   
   ### Steps to Reproduce
   
   the proxy also report a Excetion
   ERROR AdminBrokerThread_9 - process failed. msg:RemotingCommand [code=307, language=JAVA, version=441, opaque=3843, flag(B)=0, remark=null, extFields={clientId=jinduoxiadeMacBook-Pro.local@5751@1@5voc0573e, Signature=0ISOzhT8nbdxUPN+6dsrJrOHtK0=, jstackEnable=false, AccessKey=rocketmq2, consumerGroup=GID_jdx}, serializeTypeCurrentRPC=JSON]
   java.lang.NullPointerException: null
   	at org.apache.rocketmq.proxy.grpc.v2.channel.GrpcClientChannel.processGetConsumerRunningInfo(GrpcClientChannel.java:213)
   	at org.apache.rocketmq.proxy.service.relay.ProxyChannel.writeAndFlush(ProxyChannel.java:97)
   	at org.apache.rocketmq.remoting.netty.NettyRemotingAbstract.invokeSyncImpl(NettyRemotingAbstract.java:477)
   	at org.apache.rocketmq.remoting.netty.NettyRemotingServer.invokeSync(NettyRemotingServer.java:383)
   	at org.apache.rocketmq.broker.client.net.Broker2Client.callClient(Broker2Client.java:80)
   	at org.apache.rocketmq.broker.processor.AdminBrokerProcessor.callConsumer(AdminBrokerProcessor.java:2484)
   
   ### What Did You Expect to See?
   
   get the correct consumerStatus
   
   ### What Did You See Instead?
   
   the Exception
   
   ### Additional Context
   
   no


-- 
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-unsubscribe@rocketmq.apache.org.apache.org

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


Re: [I] [Bug] can not get consumerStatus [rocketmq]

Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on issue #7728:
URL: https://github.com/apache/rocketmq/issues/7728#issuecomment-2601086469

   This issue was closed because it has been inactive for 3 days since being marked as stale.


-- 
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-unsubscribe@rocketmq.apache.org

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


Re: [I] [Bug] can not get consumerStatus [rocketmq]

Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] closed issue #7728: [Bug] can not get consumerStatus
URL: https://github.com/apache/rocketmq/issues/7728


-- 
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-unsubscribe@rocketmq.apache.org

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


Re: [I] [Bug] can not get consumerStatus [rocketmq]

Posted by "Jinduoxia666 (via GitHub)" <gi...@apache.org>.
Jinduoxia666 commented on issue #7728:
URL: https://github.com/apache/rocketmq/issues/7728#issuecomment-1894974539

   > you use grpc client ? and proxy+broker deploy mode?
   
   yeah,i guess that the grpc client have some problems.


-- 
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-unsubscribe@rocketmq.apache.org

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


Re: [I] [Bug] can not get consumerStatus [rocketmq]

Posted by "github-actions[bot] (via GitHub)" <gi...@apache.org>.
github-actions[bot] commented on issue #7728:
URL: https://github.com/apache/rocketmq/issues/7728#issuecomment-2597161380

   This issue is stale because it has been open for 365 days with no activity. It will be closed in 3 days if no further activity occurs.


-- 
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-unsubscribe@rocketmq.apache.org

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


Re: [I] [Bug] can not get consumerStatus [rocketmq]

Posted by "leizhiyuan (via GitHub)" <gi...@apache.org>.
leizhiyuan commented on issue #7728:
URL: https://github.com/apache/rocketmq/issues/7728#issuecomment-1884299752

   you use grpc client ? and proxy+broker deploy mode?


-- 
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-unsubscribe@rocketmq.apache.org

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


Re: [I] [Bug] can not get consumerStatus [rocketmq]

Posted by "Jinduoxia666 (via GitHub)" <gi...@apache.org>.
Jinduoxia666 commented on issue #7728:
URL: https://github.com/apache/rocketmq/issues/7728#issuecomment-1879735566

   i try openjdk21,also report this Exception


-- 
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-unsubscribe@rocketmq.apache.org

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