KilluaChen opened a new issue, #921:
URL: https://github.com/apache/rocketmq-client-go/issues/921
### 代码片段
```golang
p, err := rocketmq.NewProducer(
producer.WithNsResolver(primitive.NewPassthroughResolver([]string{"10.1.2.3.4:8080"})),
producer.WithRetry(2),
producer.WithCredentials(primitive.Credentials{
AccessKey: "111",
SecretKey: "222",
}),
)
if err != nil {
fmt.Println("init producer error: " + err.Error())
os.Exit(0)
}
err = p.Start()
if err != nil {
fmt.Printf("start producer error: %s", err.Error())
os.Exit(1)
}
msg1 := primitive.NewMessage("debug-topic", []byte("msg1"))
msg2 := primitive.NewMessage("debug-topic", []byte("msg2"))
rst, err := p.SendSync(context.Background(), msg1, msg2)
if err != nil {
fmt.Printf("SendSync error: %s", err.Error())
os.Exit(1)
}
fmt.Println(rst)
```
### 运行报错:
```bash
SendSync error: request code unsupported, code 320
```
### 版本信息
- RocketMQ 版本: 阿里云5.0
- 客户端版本: 2.1.1
- 操作系统: MacOS 12.5
--
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.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
