event

Sep 26, 2022

Changes in this version

type KafkaConfig

+ BrokerAddresses string

+ ClientID string

+ DisableSASL bool

+ DisableTLS bool

+ Enabled bool

+ MaxMessageByte int

+ type KafkaConsumerConfig struct

+ ConsumerGroup string

+ InitialOffset *int64

+ type LogErrorFunc func(string, ...interface{})

+ type ProcessEventFunc func(interface{}) error

+ type SaramaLoger struct

+ func (s *SaramaLoger) Print(v ...interface{})

+ func (s *SaramaLoger) Printf(format string, v ...interface{})

+ func (s *SaramaLoger) Println(v ...interface{})

Dec 14, 2021

Changes in this version

+ func ConsumeKafka(ctx context.Context, kafkaConfig KafkaConfig, ...) error

+ type KafkaConfig struct

+ Broker string

+ ConsumerGroup string

+ Password string

+ Topic string

+ User string

+ Version string