You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@rocketmq.apache.org by GitBox <gi...@apache.org> on 2020/12/24 02:55:26 UTC

[GitHub] [rocketmq-client-go] refear99 opened a new issue #573: Aliyun message track using this sdk

refear99 opened a new issue #573:
URL: https://github.com/apache/rocketmq-client-go/issues/573


   使用此sdk时，消费消息成功后，阿里云那边的消息轨迹依然提示"尚未消费"
   请问如何配置呢？
   尝试了WithTrace还是不行
   
   `
   traceCfg := &primitive.TraceConfig{
   		TraceTopic:   "test_topic1",
   		GroupName:    "GID_test_group1",
   		Access:       primitive.Cloud,
   		Resolver:     primitive.NewPassthroughResolver(namesrvs),
   		Credentials: primitive.Credentials{
   			AccessKey: "ak",
   			SecretKey: "ak",
   		},
   	}
   
   	c, err := rocketmq.NewPushConsumer(
   		consumer.WithTrace(traceCfg),
   		consumer.WithGroupName("GID_test_group1"),
   		consumer.WithNameServer(namesrvs),
   		consumer.WithNamespace("实例"),
   		consumer.WithCredentials(primitive.Credentials{
   			AccessKey: "ak",
   			SecretKey: "ak",
   		}),
   		consumer.WithConsumerModel(consumer.Clustering),
   	)
   `


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

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-client-go] refear99 commented on issue #573: Aliyun message track using this sdk

Posted by GitBox <gi...@apache.org>.
refear99 commented on issue #573:
URL: https://github.com/apache/rocketmq-client-go/issues/573#issuecomment-751675478


   @ShannonDing 
   default trace topic value is RMQ_SYS_TRACE_TOPIC
   
   ```
   ERRO[0105] queryTopicRouteInfoFromServer failed          topic=RMQ_SYS_TRACE_TOPIC
   ERRO[0105] fetch publish message queues failed           underlayError="topic not exist"
   ```


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

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-client-go] ShannonDing closed issue #573: Aliyun message track using this sdk

Posted by GitBox <gi...@apache.org>.
ShannonDing closed issue #573:
URL: https://github.com/apache/rocketmq-client-go/issues/573


   


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

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-client-go] ShannonDing commented on issue #573: Aliyun message track using this sdk

Posted by GitBox <gi...@apache.org>.
ShannonDing commented on issue #573:
URL: https://github.com/apache/rocketmq-client-go/issues/573#issuecomment-751988740


   it seems to lack instance and region info.  maybe you can have a try on using the same config of the name server address in Push Consumer and TraceConfig. 
   Such as both using WithNameServer or Resolver.
   link https://github.com/apache/rocketmq-client-go/pull/474


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

For queries about this service, please contact Infrastructure at:
users@infra.apache.org

[GitHub] [rocketmq-client-go] ShannonDing commented on issue #573: Aliyun message track using this sdk

Posted by GitBox <gi...@apache.org>.
ShannonDing commented on issue #573:
URL: https://github.com/apache/rocketmq-client-go/issues/573#issuecomment-751640799


   remove the parameter TraceTopic: "test_topic1", left it as the default trace topic for aliyun.


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

For queries about this service, please contact Infrastructure at:
users@infra.apache.org