kafka

package

v0.0.0-...-d09ac20 Latest Latest Go to latest Published: Nov 1, 2019 License: Apache-2.0 Imports: 8 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

View Source

var AsyncProducer sarama.AsyncProducer

View Source

var Consumer *cluster.Consumer

View Source

var KafkaCloseSign = false

View Source

var KafkaWait sync.WaitGroup

View Source

var MsgChan = make(chan string, 1000)

View Source

var StopChan = make(chan struct{})

View Source

var StopPublishChan = make(chan struct{})

View Source

var SyncProducer sarama.SyncProducer

func AsyncProduce(log log.TLog)

异步发送

func AsyncPublishStart()

func Consume(consumer *cluster.Consumer)

func ConsumeStart()

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

func KafkaInit()

func SyncProduce(log log.TLog, message string)

同步发送

func SyncPublishStart()

This section is empty.