publisher

Sep 29, 2021

Changes in this version

+ type Message struct

+ func (m *Message) GetKey() []byte

+ func (m *Message) GetValue() interface{}

+ type MessageInterface interface

+ GetKey func() []byte

+ GetValue func() interface{}

+ func NewMessage(key string, value interface{}) MessageInterface

+ type Producer struct

+ func (p *Producer) Close()

+ func (p *Producer) ListTopics() map[string]string

+ func (p *Producer) Publish(topicNickname string, messages ...MessageInterface) error

+ func (p *Producer) Stats(topicNickname string) kafka.WriterStats

+ type ProducerInterface interface

+ Close func()

+ ListTopics func() map[string]string

+ Publish func(topicNickname string, messages ...MessageInterface) error

+ Stats func(topicNickname string) kafka.WriterStats

+ func NewProducer(monitor monitoring.MonitorInterface, ...) ProducerInterface