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 2022/08/17 03:19:33 UTC

[GitHub] [rocketmq] kelly6 opened a new issue, #4830: mqadmin consumeProgress got 'N/A' in ClientIP column when using DefaultLitePullConsumer(java)

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

   **BUG REPORT**
   
   1. Please describe the issue you observed:
   
   - start a DefaultLitePullConsumer same as the example using subscribe mode.
   - run cmd `mqadmin consumeProgress -g ... -n ... -s true`
   
   -  expect to see '192.168.x.x@.....' in ClientIP column
   
   - I got 'N/A' which DefaultPushConsumer is fine.
   
   2. Please tell us about your environment:
       broker version: 4.9.4
       client version: 4.9.4
   
   3. I'm not sure what's going wrong, liteConsumer.getClientIP() getInstanceName() is correct. what should I set to get this work?
   


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

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

[GitHub] [rocketmq] kelly6 commented on issue #4830: mqadmin consumeProgress got 'N/A' in ClientIP column when using DefaultLitePullConsumer(java)

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

   Thanks for your reply.  According to the article


-- 
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] kelly6 commented on issue #4830: mqadmin consumeProgress got 'N/A' in ClientIP column when using DefaultLitePullConsumer(java)

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

   Thanks for your reply.
   
   According to the article _DefaultMQPushConsumer_ implemented its own _ConsumerRunningInfo_.
   I'm wondaring is there an easy way to override _ConsumerRunningInfo_ for _DefaultMQPullConsumer_ ?


-- 
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] kelly6 closed issue #4830: mqadmin consumeProgress got 'N/A' in ClientIP column when using DefaultLitePullConsumer(java)

Posted by GitBox <gi...@apache.org>.
kelly6 closed issue #4830: mqadmin consumeProgress got 'N/A' in ClientIP column when using DefaultLitePullConsumer(java)
URL: https://github.com/apache/rocketmq/issues/4830


-- 
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] kelly6 commented on issue #4830: mqadmin consumeProgress got 'N/A' in ClientIP column when using DefaultLitePullConsumer(java)

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

   Thanks for your reply.


-- 
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] YangJodie commented on issue #4830: mqadmin consumeProgress got 'N/A' in ClientIP column when using DefaultLitePullConsumer(java)

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

   > **BUG REPORT**
   > 
   > 1. Please describe the issue you observed:
   > 
   > * start a DefaultLitePullConsumer same as the example using subscribe mode.
   > * run cmd `mqadmin consumeProgress -g ... -n ... -s true`
   > * expect to see '192.168.x.x@.....' in ClientIP column
   > * I got 'N/A' which DefaultPushConsumer is fine.
   > 
   > 2. Please tell us about your environment:
   >    broker version: 4.9.4
   >    client version: 4.9.4
   > 3. I'm not sure what's going wrong, liteConsumer.getClientIP() getInstanceName() is correct. what should I set to get this work?
   
   DefaultLitePullConsumer/DefaultPullConsumer implement only the functionality necessary for pull message. Consumer managment like offset query or direct push is not available.


-- 
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] francisoliverlee commented on issue #4830: mqadmin consumeProgress got 'N/A' in ClientIP column when using DefaultLitePullConsumer(java)

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

   as i know, DefaultLitePullConsumer doest report its client to broker
   and DefaultPushConsumer does. [here is a doc for your consideration](https://mp.weixin.qq.com/s?__biz=Mzg4NDUzMzcwMQ==&mid=2247483946&idx=1&sn=d55e6ce58e597fcb1dcf3bd7477c8a66)


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