string OffsetTable map[primitive.MessageQueue]int64 `json:"OffsetTable"` client internal.RMQClient...rocketmq-client-go-v2.0.0/consumer/offset_store.go func NewRemoteOffsetStore(group string, client internal.RMQClient
defaultPullConsumer struct { *defaultConsumer option consumerOptions client internal.RMQClient
/producer/producer.go type defaultProducer struct { group string client internal.RMQClient
领取专属 10元无门槛券
手把手带您无忧上云
云服务器
ICP备案
实时音视频
对象存储
即时通信 IM
