Versions in this module Expand all Collapse all v0 v0.0.1 Aug 7, 2025 Changes in this version + type ConsumerConf struct + AccessKey string + AutoCommit bool + ConsumerModel string + GroupName string + InstanceName string + MaxReconsumeTimes int32 + Namespace string + NsResolver []string + RebalanceLockInterval int + Resolver string + SecretKey string + Strategy string + func (c *ConsumerConf) MustNewPullConsumer() rocketmq.PullConsumer + func (c *ConsumerConf) MustNewPushConsumer() rocketmq.PushConsumer + func (c *ConsumerConf) Validate() error + type ProducerConf struct + AccessKey string + CompressLevel int + CompressMsgBodyOverHowMuch int + CreateTopicKey string + DefaultTopicQueueNums int + GroupName string + InstanceName string + MsgTimeOut int + Namespace string + NsResolver []string + Retry int + SecretKey string + func (c *ProducerConf) MustNewProducer() rocketmq.Producer + func (c *ProducerConf) Validate() error
Go to main page