apache / apache/rocketmq-client-go
ConsumeFromLastOffset problem
- 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
Assessment
This issue has not been assessed yet.