consumer

Sep 22, 2024

Changes in this version

type KafkaConsumerOpts

+ SASLConfig *KafkaSASLOpts

+ type KafkaSASLOpts struct

+ Password string

+ Username string

Oct 2, 2023

Changes in this version

+ type Event struct

+ ID uuid.UUID

+ PartyID uuid.UUID

+ Payload interface{}

+ Publisher string

+ Type string

Sep 6, 2023

Changes in this version

+ type Consumer interface

+ Close func()

+ RegisterHandler func(handler EventHandler)

+ Start func(ctx context.Context)

+ func NewKafkaConsumer(opts *KafkaConsumerOpts) Consumer

+ type EventHandler interface

+ Handle func(ctx context.Context, event map[string]interface{}) error

+ Name func() string

+ type KafkaConsumerOpts struct

+ Brokers string

+ GroupID string

+ MaxBytes int

+ MaxRetry int

+ MinBytes int

+ Topic string