apache / apache/rocketmq-client-go
When connecting to the AliCloud RocketMQ product for consumption via TCP endpoint, the AliCloud console queries the message track by Message Id, and there is no consumption or consumption failure.
- Dominant language
- Go
- Stars
- 1.4k
- Forks
- 445
- PR merge metrics
- No merged PRs in 30d
Description
> 通过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系列`
日志信息:`显示都是正常的`
Contributor guide
Assessment
This issue has not been assessed yet.