Struct drainHandler

consumer_group_test.go:344–344

drainHandler is a ConsumerGroupHandler that drains messages without blocking.

// drainHandler is a ConsumerGroupHandler that drains messages without blocking.
type drainHandler struct{}

func (*drainHandler) Setup(_ ConsumerGroupSession) error   { return nil }
func (*drainHandler) Cleanup(_ ConsumerGroupSession) error { return nil }