Struct causeHandler

consumer_group_test.go:356–358

causeHandler is a ConsumerGroupHandler that captures the context.Cause when the session context is canceled.

// causeHandler is a ConsumerGroupHandler that captures the context.Cause when
// the session context is canceled.
type causeHandler struct {
	causeCh chan error
}

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