consumer_group newSession() infinite loop

[nbajaj90]

sarama/consumer_group.go

Line 311 in 9e75986

return c.newSession(ctx, topics, handler, retries)

If the error is ErrUnknownMemberId and context gets cancelled by some other go-routine, the above code can go in an infinite loop.

Need a check to cross-check if context is cancelled before below switch:

sarama/consumer_group.go

Line 305 in 9e75986

switch join.Err {

Example code required:
select { case <-ctx.Done(): return nil, ctx.Err() default: }

[dnwe]

Thanks, this is a general bug that the newSession and retryNewSession funcs should both be checking for ctx cancellation to exit early before proceeding