Versions in this module Expand all Collapse all v0 v0.0.6 Aug 3, 2022 Changes in this version + func NewKafkaReceiver(address []string, topic string) (event.Receiver, error) + func NewKafkaSender(address []string, topic string) (event.Sender, error)
Go to main page