apache / rocketmq-client-go

Apache RocketMQ go client
https://rocketmq.apache.org/
Apache License 2.0
1.29k stars 415 forks source link

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. #1089

Open huge-kumo opened 1 year ago

huge-kumo commented 1 year ago

通过TCP endpoint方式去连接阿里云RocketMQ产品进行消费时,阿里云控制台上通过Message Id去查询消息轨迹,出现未消费或者消费失败。

观察到的

  1. 我使用github.com/apache/rocketmq-client-go/v2库通过TCP Endpoint的方式去连接阿里云RocketMQ产品。

    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系列 日志信息:显示都是正常的

francisoliverlee commented 12 months ago

可以给阿里云提个工单

Onehr7 commented 9 months ago

@huge-kumo 请问最后是怎么解决的

huge-kumo commented 9 months ago

@huge-kumo 请问最后是怎么解决的

和阿里云沟通以后,最终还是以实际消费为准,阿里云后台上的消息轨迹我也不用了,等于使用阿里云官方sdk才能上报消息轨迹。