refear99 opened a new issue #573:
URL: https://github.com/apache/rocketmq-client-go/issues/573
使用此sdk时,消费消息成功后,阿里云那边的消息轨迹依然提示"尚未消费"
请问如何配置呢?
尝试了WithTrace还是不行
`
traceCfg := &primitive.TraceConfig{
TraceTopic: "test_topic1",
GroupName: "GID_test_group1",
Access: primitive.Cloud,
Resolver: primitive.NewPassthroughResolver(namesrvs),
Credentials: primitive.Credentials{
AccessKey: "ak",
SecretKey: "ak",
},
}
c, err := rocketmq.NewPushConsumer(
consumer.WithTrace(traceCfg),
consumer.WithGroupName("GID_test_group1"),
consumer.WithNameServer(namesrvs),
consumer.WithNamespace("实例"),
consumer.WithCredentials(primitive.Credentials{
AccessKey: "ak",
SecretKey: "ak",
}),
consumer.WithConsumerModel(consumer.Clustering),
)
`
----------------------------------------------------------------
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.
For queries about this service, please contact Infrastructure at:
[email protected]