client

Nov 21, 2023

Changes in this version

+ var Consumers []consumer.Consumer

+ var Producer producer.Producer

Nov 17, 2023

Changes in this version

+ var ConsumerTopics []consumer.Topic

+ var ProducerTopics []producer.Topic

+ func NewClient(k pkg.Kafka, _c *config.Config) pkg.Client

+ type Client struct

+ func (c *Client) Produce(m message.Message) error

+ func (c *Client) RegisterConsumerHandler(ct consumer.Topic) error

+ type Handler func(interface{}, []byte) error