Struct handler

consumer_group_test.go:17–19

)

type handler struct {
	messageCh chan *ConsumerMessage
}

func (h *handler) Setup(s ConsumerGroupSession) error   { return nil }
func (h *handler) Cleanup(s ConsumerGroupSession) error { return nil }