kafka

README

Kafka

1.

Documentation

Index

• Variables
• func AsyncProduce(log log.TLog)
• func AsyncPublishStart()
• func Consume(consumer *cluster.Consumer)
• func ConsumeStart()
• func KafkaInit()
• func SyncProduce(log log.TLog, message string)
• func SyncPublishStart()

Variables

var AsyncProducer sarama.AsyncProducer

var Consumer *cluster.Consumer

var KafkaCloseSign = false

var KafkaWait sync.WaitGroup

var MsgChan = make(chan string, 1000)

var StopChan = make(chan struct{})

var StopPublishChan = make(chan struct{})

var SyncProducer sarama.SyncProducer

Functions

func AsyncProduce

func AsyncProduce(log log.TLog)

异步发送

func AsyncPublishStart

func AsyncPublishStart()

func Consume

func Consume(consumer *cluster.Consumer)

func ConsumeStart

func ConsumeStart()

"github.com/Shopify/sarama"不支持consume group,故选择再次封装的"github.com/bsm/sarama-cluster"

func KafkaInit

func KafkaInit()

func SyncProduce

func SyncProduce(log log.TLog, message string)

同步发送

func SyncPublishStart

func SyncPublishStart()