package
0.0.0-20231108073916-93b22619600a
Repository: https://github.com/kdcer/go-lib.git
Documentation: pkg.go.dev

# Functions

异步生产消息topic 主题data 数据.
异步生产消息 多步骤消息使,消费端调用,消费成功后调用发送下一步的消息topic 主题data 数据uuid 要替换的原消息uuiddepth 消费的深度,如果存在则把消息的ConsumerDepth从depth-1改为depth.
No description provided by the author
No description provided by the author
异步消息.

# Constants

协程池handlerName.
协程池handlerName.

# Variables

var address = strings.Split(g.Cfg().GetString("kafka.host"), ",").

# Structs

No description provided by the author