Versions in this module Expand all Collapse all v1 v1.0.1 Nov 30, 2020 Changes in this version + func NewKafkaEventEmitter(client sarama.Client) (msgqueue.EventEmitter, error) + func NewKafkaEventEmitterFromEnvironment() (msgqueue.EventEmitter, error) + func NewKafkaEventListener(client sarama.Client, partitions []int32) (msgqueue.EventListener, error) + func NewKafkaEventListenerFromEnvironment() (msgqueue.EventListener, error)
Go to main page