huge-kumo opened a new issue, #1089:
URL: https://github.com/apache/rocketmq-client-go/issues/1089
> 通过TCP endpoint方式去连接阿里云RocketMQ产品进行消费时,阿里云控制台上通过Message
Id去查询消息轨迹,出现未消费或者消费失败。
# 观察到的
1. 我使用`github.com/apache/rocketmq-client-go/v2`库通过TCP
Endpoint的方式去连接阿里云RocketMQ产品。
```go
mqConsumer.client, err = rocketmq_client_go.NewPushConsumer(
consumer.WithTrace(&primitive.TraceConfig{
GroupName: groupId,
Access: primitive.Cloud,
NamesrvAddrs: mqInstance.endPoints,
Credentials: primitive.Credentials{AccessKey:
mqInstance.accessKey, SecretKey: mqInstance.secretKey},
}),
consumer.WithGroupName(groupId),
consumer.WithNameServer(mqInstance.endPoints),
consumer.WithNamespace(mqInstance.instanceId),
consumer.WithCredentials(primitive.Credentials{AccessKey:
mqInstance.accessKey, SecretKey: mqInstance.secretKey}),
consumer.WithConsumerModel(mm),
consumer.WithAutoCommit(true),
consumer.WithConsumeMessageBatchMaxSize(1),
)
```
2. 我希望在阿里云控制台上,通过Message ID能够显示该消息成功的消费轨迹。
3. 但实际上,我这边阿里云控制台上显示的只有两种情况,一种是未消费,一种是消费失败(消息结果未返回)。
# 运行环境
操作系统:`MacOS arm`
客户端环境:`github.com/apache/rocketmq-client-go/v2 v2.1.1`
RocketMQ版本:`4.0系列`
日志信息:`显示都是正常的`
--
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: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]