Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrProducer = errors.New("kafka producer nil") ErrConsumer = errors.New("kafka consumer nil") )
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer struct { ConsumerGroup *consumergroup.ConsumerGroup // contains filtered or unexported fields }
kafka consumer
func NewConsumer ¶
func NewConsumer(c *conf.KafkaConsumer) (kc *Consumer)
type Producer ¶
type Producer struct { sarama.AsyncProducer sarama.SyncProducer // contains filtered or unexported fields }
func NewProducer ¶
func NewProducer(c *conf.KafkaProducer) (p *Producer)
NewProducer new kafka async producer and retry when has error.
Click to show internal directories.
Click to hide internal directories.