Versions in this module Expand all Collapse all v0 v0.0.2 Oct 27, 2023 v0.0.1 Oct 26, 2023 Changes in this version + type Antenna struct + func NewAntenna(topic string, brokers []string, groupID string, opts ...Option) *Antenna + func (a *Antenna) Run() error + func (a *Antenna) Stop() + type Handler interface + Process func(ctx context.Context, msg kafka.Message) error + type HandlerFunc func(ctx context.Context, msg kafka.Message) error + func (f HandlerFunc) Process(ctx context.Context, msg kafka.Message) error + type Logger interface + Printf func(string, ...interface{}) + type LoggerFunc func(msg string, args ...any) + func (f LoggerFunc) Printf(msg string, args ...any) + type OffsetProvider interface + GetOffset func(ctx context.Context, topic string, partition int) (int64, error) + type Option func(*Antenna) + func WithErrorLogger(logger Logger) Option + func WithLogger(logger Logger) Option + func WithMessageHandler(handler Handler) Option + func WithOffsetProvider(offsetProvider OffsetProvider) Option
Go to main page