kafka

Jul 4, 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)