kafka

Jan 7, 2020

Changes in this version

+ type AsyncProducer struct

+ func (p *AsyncProducer) Produce(topic, value string)

type Kafka

+ func (q *Kafka) AsyncProducer() (*AsyncProducer, error)

+ func (q *Kafka) Close() error

+ func (q *Kafka) SyncProducer() (*SyncProducer, error)

+ type SyncProducer struct

+ func (p *SyncProducer) Produce(topic, value string) (partition int32, offset int64, err error)

Aug 30, 2019

Changes in this version

+ type Consumer struct

+ func (c *Consumer) Close()

+ func (c *Consumer) Consume(cb func([]byte)) error

+ type Kafka struct

+ func Ins(id ...string) *Kafka

+ func NewKafka(connect string, config *cluster.Config) *Kafka

+ func (q *Kafka) NewConsumer(topic string, group string) (*Consumer, error)

+ func (q *Kafka) Produce(topic string, value string) (partition int32, offset int64, err error)