Function NewHandler

pkg/samarap/handler.go:16–18

NewHandler 创建一个新的 Handler 实例

(logger *zap.Logger, handle func(msg *sarama.ConsumerMessage, event T) error)

// NewHandler 创建一个新的 Handler 实例
func NewHandler[T any](logger *zap.Logger, handle func(msg *sarama.ConsumerMessage, event T) error) *Handler[T] {
	return &Handler[T]{logger: logger, handle: handle}
}

// Setup 在消费组会话开始时调用
func (h *Handler[T]) Setup(session sarama.ConsumerGroupSession) error {