sarama_client

Documentation

Index

• func AsyncProducer()
• func Consumer()
• func SyncProducer()

Functions

func AsyncProducer

func AsyncProducer()

* 异步生产

初始化NewConfig配置 sarama.NewConfig
创建生产者sarama.NewAsyncProducer
创建消息sarama.ProducerMessage
发送消息producer.Input() <- msg
接收消息回调：select：{suc := <-producer.Successes()}{fail := <-producer.Errors()}

func Consumer

func Consumer()

func SyncProducer

func SyncProducer()

同步生产

初始化NewConfig配置 sarama.NewConfig
创建生产者sarama.NewSyncProducer
创建消息sarama.ProducerMessage
发送消息client.SendMessage，同步获取返回信息