Function NewBatchHandler

pkg/samarap/handler_batch.go:17–19

(l *zap.Logger, fn func(msgs []*sarama.ConsumerMessage, ts []T) error)

}

func NewBatchHandler[T any](l *zap.Logger, fn func(msgs []*sarama.ConsumerMessage, ts []T) error) *BatchHandler[T] {
	return &BatchHandler[T]{fn: fn, l: l}
}

func (b *BatchHandler[T]) Setup(session sarama.ConsumerGroupSession) error {
	return nil