Struct Handler

pkg/samarap/handler.go:10–13

Handler 是一个通用的消息处理器

// Handler 是一个通用的消息处理器
type Handler[T any] struct {
	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] {