Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

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 this issue Sep 1, 2023 · 3 comments
Labels
question Further information is requested

Comments

@huge-kumo
Copy link

通过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),
)
  1. 我希望在阿里云控制台上,通过Message ID能够显示该消息成功的消费轨迹。

  2. 但实际上,我这边阿里云控制台上显示的只有两种情况,一种是未消费,一种是消费失败(消息结果未返回)。

运行环境

操作系统:MacOS arm
客户端环境:github.com/apache/rocketmq-client-go/v2 v2.1.1
RocketMQ版本:4.0系列
日志信息:显示都是正常的

@francisoliverlee francisoliverlee added the question Further information is requested label Sep 14, 2023
@francisoliverlee
Copy link
Member

可以给阿里云提个工单

@Onehr7
Copy link

Onehr7 commented Dec 7, 2023

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

@huge-kumo
Copy link
Author

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

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

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
question Further information is requested
Projects
None yet
Development

No branches or pull requests

3 participants