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/04/13 00:56:21 UTC
[GitHub] [rocketmq] xunianchong opened a new issue, #4160: who to save msg offset on k8s
xunianchong opened a new issue, #4160:
URL: https://github.com/apache/rocketmq/issues/4160
application deply on k8s , now i redeploy the application, alway receive the history msg. Consumer send msg by MessageModel of CLUSTERING , how do I save the msg offset ? how can i set the InstanceName? tank you
--
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] xunianchong commented on issue #4160: who to save msg offset on k8s
Posted by GitBox <gi...@apache.org>.
xunianchong commented on issue #4160:
URL: https://github.com/apache/rocketmq/issues/4160#issuecomment-1097453931
DefaultMQPushConsumer consumer =
new DefaultMQPushConsumer("BB");
consumer.setInstanceName("AA");
We need to use a fixed InstanceName or a fixed consumerGroup name? consumerGroup is fixed?
--
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] pingww commented on issue #4160: who to save msg offset on k8s
Posted by GitBox <gi...@apache.org>.
pingww commented on issue #4160:
URL: https://github.com/apache/rocketmq/issues/4160#issuecomment-1099960754
Observe the offset submission record in the RMQ client log
--
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 #4160: who to save msg offset on k8s
Posted by GitBox <gi...@apache.org>.
duhenglucky closed issue #4160: who to save msg offset on k8s
URL: https://github.com/apache/rocketmq/issues/4160
--
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] lwclover commented on issue #4160: who to save msg offset on k8s
Posted by GitBox <gi...@apache.org>.
lwclover commented on issue #4160:
URL: https://github.com/apache/rocketmq/issues/4160#issuecomment-1097486640
InstanceName is optional unless multiple consumers are started within a process
--
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] lwclover commented on issue #4160: who to save msg offset on k8s
Posted by GitBox <gi...@apache.org>.
lwclover commented on issue #4160:
URL: https://github.com/apache/rocketmq/issues/4160#issuecomment-1097486039
> DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("BB"); consumer.setInstanceName("AA");
>
> We need to use a fixed InstanceName or a fixed consumerGroup name? consumerGroup is fixed?
Yes, the consumerGroup 'BB' need a Fixed name.
--
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] lwclover commented on issue #4160: who to save msg offset on k8s
Posted by GitBox <gi...@apache.org>.
lwclover commented on issue #4160:
URL: https://github.com/apache/rocketmq/issues/4160#issuecomment-1097449756
> deply
You need to use a fixed consumerGroup name.
--
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] lwclover commented on issue #4160: who to save msg offset on k8s
Posted by GitBox <gi...@apache.org>.
lwclover commented on issue #4160:
URL: https://github.com/apache/rocketmq/issues/4160#issuecomment-1097485825
> DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("BB"); consumer.setInstanceName("AA");
>
> We need to use a fixed InstanceName or a fixed consumerGroup name? consumerGroup is fixed?
DefaultMQPushConsumer consumer = new DefaultMQPushConsumer("BB");
Yes, the consumerGroup 'BB' need a Fixed name.
--
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