这个 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 奈何水平不够……
