吐个槽,有人在用 rocketmq-client-go 吗
資深大佬 : sunday9th 5
这个 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 奈何水平不够……
大佬有話說 (5)