kafka

type MessageSinkConfig struct {
	Topic           string
	Brokers         []string
	KeyFunc         func(pubsub.ProducerMessage) []byte
	MaxMessageBytes int
	Version         *sarama.KafkaVersion
}

type MessageSourceConfig struct {
	ConsumerGroup            string
	Topic                    string
	Brokers                  []string
	Offset                   int64
	MetadataRefreshFrequency time.Duration
	OffsetsRetention         time.Duration
	Version                  *sarama.KafkaVersion
}