kafka

Jul 23, 2021

Changes in this version

+ type Consumer interface

+ Close func()

+ Subscribe func(ctx context.Context, callbackFn func(event *Event, err error))

+ type Event struct

+ Header map[string]string

+ Key []byte

+ Time time.Time

+ Topic string

+ Value []byte

+ type Kafka interface

+ Debug func(debug bool)

+ NewConsumer func(groupID, topic string) Consumer

+ NewProducer func(topic string) Producer

+ func New(kafkaBrokerUrls []string, clientId string) Kafka

+ type Producer interface

+ Close func()

+ Publish func(ctx context.Context, key, value []byte) error