Versions in this module Expand all Collapse all v0 v0.3.0 Jan 9, 2019 v0.2.1 Nov 28, 2018 Changes in this version + type KafkaCluster interface + NewConsumer func(groupID string, topics []string) (KafkaConsumer, error) + type KafkaConsumer interface + Close func() (err error) + MarkOffset func(msg *sarama.ConsumerMessage, metadata string) + Messages func() <-chan *sarama.ConsumerMessage + type KafkaDispatcher struct + func NewDispatcher(brokers []string, logger *zap.Logger) (*KafkaDispatcher, error) + func (d *KafkaDispatcher) ConfigDiff(updated *multichannelfanout.Config) string + func (d *KafkaDispatcher) Start(stopCh <-chan struct{}) error + func (d *KafkaDispatcher) UpdateConfig(config *multichannelfanout.Config) error
Go to main page