You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by GitBox <gi...@apache.org> on 2022/11/09 08:59:21 UTC
[GitHub] [rocketmq-client-go] ckall opened a new issue, #958: ConsumeFromLastOffset problem
ckall opened a new issue, #958:
URL: https://github.com/apache/rocketmq-client-go/issues/958
I have set ConsumeFromLastOffset (a new consumption group) when I use Rocketmq consumer to consume, but I still consume the old data after starting. I have seen the code in it. The first time I obtained the offset, it was 0. But I think Rocketmq go sdk needs - 1 to obtain the maximum offset. Do you encounter this situation and how to solve it
---------
c, err := rocketmq.NewPushConsumer(
consumer.WithCredentials(credential),
consumer.WithNameServer([]string{endpoint}),
consumer.WithNamespace(instanceID),
consumer.WithGroupName(groupId),
consumer.WithInstance(getInstanceName(topic)),
consumer.WithAutoCommit(true),
consumer.WithConsumerModel(consumer.Clustering),
consumer.WithConsumeFromWhere(consumer.ConsumeFromLastOffset),
consumer.WithConsumeMessageBatchMaxSize(1),
consumer.WithTrace(&primitive.TraceConfig{
//TraceTopic: topic,
GroupName: groupId,
Access: primitive.Cloud,
NamesrvAddrs: []string{endpoint},
Credentials: credential,
Resolver: primitive.NewPassthroughResolver([]string{endpoint}),
}),
)
--------
--
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
[GitHub] [rocketmq-client-go] francisoliverlee commented on issue #958: ConsumeFromLastOffset problem
Posted by "francisoliverlee (via GitHub)" <gi...@apache.org>.
francisoliverlee commented on issue #958:
URL: https://github.com/apache/rocketmq-client-go/issues/958#issuecomment-1465465548
my pleasure
--
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
[GitHub] [rocketmq-client-go] ofttryaj commented on issue #958: ConsumeFromLastOffset problem
Posted by GitBox <gi...@apache.org>.
ofttryaj commented on issue #958:
URL: https://github.com/apache/rocketmq-client-go/issues/958#issuecomment-1345156195
I have the same question
--
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
[GitHub] [rocketmq-client-go] francisoliverlee commented on issue #958: ConsumeFromLastOffset problem
Posted by "francisoliverlee (via GitHub)" <gi...@apache.org>.
francisoliverlee commented on issue #958:
URL: https://github.com/apache/rocketmq-client-go/issues/958#issuecomment-1455390597
#886 had solved the problem, you can check it on master
--
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
[GitHub] [rocketmq-client-go] CoderReaper commented on issue #958: ConsumeFromLastOffset problem
Posted by "CoderReaper (via GitHub)" <gi...@apache.org>.
CoderReaper commented on issue #958:
URL: https://github.com/apache/rocketmq-client-go/issues/958#issuecomment-1519616718
It seems that the issue is still not fixed, as the new consumer group is still consuming old message.
with set :ConsumeFromLastOffset
--
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
[GitHub] [rocketmq-client-go] ckall commented on issue #958: ConsumeFromLastOffset problem
Posted by "ckall (via GitHub)" <gi...@apache.org>.
ckall commented on issue #958:
URL: https://github.com/apache/rocketmq-client-go/issues/958#issuecomment-1455396301
Thank you. I will close this issue after my experiment is successful
--
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
[GitHub] [rocketmq-client-go] CoderReaper commented on issue #958: ConsumeFromLastOffset problem
Posted by "CoderReaper (via GitHub)" <gi...@apache.org>.
CoderReaper commented on issue #958:
URL: https://github.com/apache/rocketmq-client-go/issues/958#issuecomment-1519616979
It seems that the issue is still not fixed, as the new consumer group is still consuming old message.
with set :ConsumeFromLastOffset
--
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