Categorygithub.com/tiny911/gobasekafka
package
0.0.0-20210716104208-1ca2abd9be99
Repository: https://github.com/tiny911/gobase.git
Documentation: pkg.go.dev
Overview
Versions
1
Dependencies
6
Dependents
0
Files
144 SLOC

# Functions

NewConsumer 根据broker的addrs地址，生成Consumer实例.
NewProducer 根据broker的addrs地址，生成Producer实例.

# Structs

Consumer 消费者.
Producer 生产者，封装sarama异步生产.

# Type aliases

Handler 从kafka拉取消息后，进行回调处理的handler.