这个 go 客户端感觉还是个半成品
pushconsumer 的取消订阅直接就是啥都不干
func (pc *pushConsumer) Unsubscribe(string) error {
	return nil
}
pullconsumer 干脆就没实现
// The PullConsumer will be supported in next release
func NewPullConsumer(opts ...consumer.Option) (PullConsumer, error) {
	return nil, errors.New("pull consumer has not supported")
}
降级方案是使用可能会变更的 consumer.NewPullConsumer(),但是 new 出来的 defaultPullConsumer,没实现 PullConsumer 接口。
定义的错误在 internal 下面,外面导出的错误定义根本没用到。
好了吐槽完了,想提 pr 奈何水平不够……
|  |      1676529483      2020-12-04 15:30:06 +08:00 这个就阿里在维护,我们公司买的阿里云的 rocketmq,找他们问为啥内存这么高,说到 limit 就掉下来了,建议用 java 。。。 总结:如果不是 java/cpp/.net 这几个官方维护的 sdk,尽量避免吧 | 
|      2AIFNI45Mdxn      2020-12-04 16:31:25 +08:00 可以提交工单具体排查一下原因 | 
|      3zzzbkl      2020-12-04 16:59:52 +08:00 via Android 这玩意儿现在出纯 go 实现的稳定版了吗 之前通过 cgo 调用实现的稳定版,调用频繁了之后总是会有奇怪的崩溃出现 于是我们直接弃用 rocketmq 了 | 
|      4Firewine      2020-12-04 17:20:12 +08:00 via Android nsq 不香吗,为啥非要用 rocketmq | 
|  |      5tiedan      2020-12-04 18:18:50 +08:00 别说了, 太几把坑了 | 
|      6SteveWoo      2020-12-11 11:42:49 +08:00 工作中不得不用 rocketmq, 我们自己完全重写了 golangSDK,已经线上运行一年了,目前比较稳定。 |