route info not found

[willis-yang]

` rlog.SetOutputPath("./logs/rocketmq-client-go.log")

nameserverReslover := primitive.NewPassthroughResolver([]string{Endpoint})

//traceCfg := &primitive.TraceConfig{
//  Access:   primitive.Cloud,
//  Resolver: nameserverReslover,
//}
c, err := rocketmq.NewPushConsumer(

    consumer.WithGroupName(ConsumerGroup),

    consumer.WithNsResolver(nameserverReslover),

    consumer.WithCredentials(primitive.Credentials{
        SecretKey: SecretKey,
        AccessKey: AccessKey,
    }),
    consumer.WithConsumerModel(consumer.BroadCasting),

    consumer.WithNamespace(""),

    //consumer.WithTrace(traceCfg),
)
if err != nil {
    fmt.Println("init consumer error: " + err.Error())
    os.Exit(0)
}

err = c.Subscribe(Topic, consumer.MessageSelector{
    Type:       consumer.TAG,
    Expression: "*",
}, func(ctx context.Context,
    msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error) {
    fmt.Printf("subscribe callback: %v \n", msgs)
    return consumer.ConsumeSuccess, nil
})
if err != nil {
    fmt.Printf("subscribe callback error: %v", err)
}

err = c.Start()
if err != nil {
    fmt.Printf("start Consumer error:%v", err.Error())
    os.Exit(-1)
}
time.Sleep(time.Hour)
err = c.Shutdown()
if err != nil {
    fmt.Printf("Shutdown Consumer error: %s", err)
}`

[willis-yang]

569 using aliyuncloud rocketmq namespace error problem