com

Dec 19, 2023

Changes in this version

+ type FactoryInterface interface

+ NewConsumer func(ctx context.Context, config util.Config, ...) (err error)

+ NewProducer func(ctx context.Context, config util.Config) (ProducerInterface, error)

+ type ProducerInterface interface

+ Produce func(topic string, message string) (err error)

+ ProduceWithKey func(topic string, key string, message string) (err error)