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.

Open
#1,089 3 comments 0 reactions 0 assignees View on GitHub
question
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

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.