Method Next

consumergroup.go:701–712

Next waits for the next consumer group generation. There will never be two active generations. Next will never return a new generation until the previous one has completed. If there are errors setting up the next generation, they will be surfaced here. If the ConsumerGroup has been closed, then

(ctx context.Context)

//
// If the ConsumerGroup has been closed, then Next will return ErrGroupClosed.
func (cg *ConsumerGroup) Next(ctx context.Context) (*Generation, error) {
	select {
	case <-ctx.Done():
		return nil, ctx.Err()
	case <-cg.done:
		return nil, ErrGroupClosed
	case err := <-cg.errs:
		return nil, err
	case next := <-cg.next:
		return next, nil
	}
}

func (cg *ConsumerGroup) run() {
	// the memberID is the only piece of information that is maintained across