AsBatchProducer 设置Producer为批发送模式,不推荐.

New 创建一个新的kafka Producer客户端代理.

WithAcks 设置发送的消息需要kafka中多少个成员确认params acks int kafka成员确认数量, 0表示不需要确认,-1表示需要全部成员确认,如果是其他正整数则不可以少于集群的最小成员数min.insync.replicas,默认为-1.

WithoutConfirmDelivery 设置不监听确认发送成功与否.

WithParallelCallback 设置callback并行执行.

WithProducerSetting 设置监听时的其他设置,具体设置可以看<https://github.com/edenhill/librdkafka/blob/master/CONFIGURATION.md>和<https://github.com/confluentinc/confluent-kafka-go/blob/master/kafka/producer.go>中`NewProducer`的说明@params key string 设置项@params value any 设置项的值.

WithQueueBufferingMaxDelay 设置发送消息时构建消息批传送给kafka之前等待生产者队列中的消息积累的延迟params delay int 构建消息批传送给kafka之前等待生产者队列中的消息积累的延迟,单位ms.

Default 默认的kafka Producer代理对象.

ErrDeliverIsWatching 代理还未设置客户端对象.

ErrProxyAllreadySettedClient 代理已经设置过redis客户端对象.

ErrProxyNotYetSettedClient 代理还未设置客户端对象.

Option 设置key行为的选项.

ProducerProxy redis客户端的代理.

SetConnectCallback.