ConsumerGroup.Close can infinitely lock

maqdev · maqdev · commit c3a563b4f1c8 · 2023-11-13T16:21:03.000-08:00
Signed-off-by: Magomed Abdurakhmanov &lt;maqdev@gmail.com&gt;
diff --git a/consumer_group.go b/consumer_group.go
@@ -217,7 +217,6 @@ func (c *consumerGroup) Consume(ctx context.Context, topics []string, handler Co
 	select {
 	case <-c.closed:
 	case <-sess.ctx.Done():
-	default:
 	}
 
 	// Gracefully release session claims

Original file line number	Diff line number	Diff line change
`@@ -217,7 +217,6 @@ func (c *consumerGroup) Consume(ctx context.Context, topics []string, handler Co`
`217`	`217`	`select {`
`218`	`218`	`case <-c.closed:`
`219`	`219`	`case <-sess.ctx.Done():`
`220`		`- default:`
`221`	`220`	`}`
`222`	`221`
`223`	`222`	`// Gracefully release session claims`