Versions in this module Expand all Collapse all v0 v0.1.8 Oct 24, 2019 Changes in this version + type Kafka struct + func NewKafka(addrs []string) *Kafka + func (k *Kafka) AsyncProducer(ctx context.Context, msg chan *sarama.ProducerMessage, sf successFunc, ...) + func (k *Kafka) Close() + func (k *Kafka) Consumer(ctx context.Context, topic string, partition int32, offset int64, rf rmsgFunc, ...) + func (k *Kafka) ConsumerGroup(ctx context.Context, gid string, topics []string, rf rmsgFunc) + func (k *Kafka) SyncProducer(msg *sarama.ProducerMessage) (part int32, offset int64, err error)
Go to main page