base

May 8, 2023

Changes in this version

+ func Batch(n int, d time.Duration, in <-chan T) <-chan []T

+ func EventKey(source string, subject string) string

+ type Kafka struct

+ Logger *zap.SugaredLogger

+ func NewKafka(config *eventbusv1alpha1.KafkaBus, logger *zap.SugaredLogger) *Kafka

+ func (k *Kafka) Brokers() []string

+ func (k *Kafka) Config() (*sarama.Config, error)

+ type KafkaConnection struct

+ Logger *zap.SugaredLogger

+ func NewKafkaConnection(logger *zap.SugaredLogger) *KafkaConnection