kafka

Jan 2, 2023

Changes in this version

+ type Consumer interface

+ AddClaimer func(string, MessageClaimer)

+ AddCleanupHook func(hook Hook)

+ AddSetupHook func(hook Hook)

+ type Hook func(session sarama.ConsumerGroupSession)

+ type MessageClaimer func(*sarama.ConsumerMessage) bool

+ type Server interface

+ Close func() error

+ GetConsumer func() sarama.ConsumerGroup

+ Listen func(wg *sync.WaitGroup, close <-chan struct{})

Jun 4, 2022

Changes in this version

+ func New(config Config) func(ctx context.Context) error

+ type Config struct

+ Bootstrap []string

+ CustomTopicName string

+ ServiceName string

+ Timeout time.Duration

+ Version string