Versions in this module Expand all Collapse all v0 v0.3.0 Dec 31, 2020 v0.2.0 Nov 13, 2020 v0.1.3 Mar 9, 2020 Changes in this version + type KafkaSender struct + Debug bool + Target KafkaTarget + func (s *KafkaSender) SendMessage(message []byte) error + type KafkaTarget struct + Brokers []string + Topic string + WriteTimeout time.Duration + type Sender interface + SendMessage func([]byte) error
Go to main page