apache / apache/rocketmq-client-go

ConsumeFromLastOffset problem

Open
#958 5 comments 0 reactions 0 assignees View on GitHub
need-more-info offset
Dominant language
Go
Stars
1.4k
Forks
445
PR merge metrics
No merged PRs in 30d

Description

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}),
}),
)
--------

Contributor guide

Open the contributing guide

Assessment

This issue has not been assessed yet.

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.