From ad83978a1961eb6fa25d4764ec26580f0185770b Mon Sep 17 00:00:00 2001
From: Varun Kumar <varunkumar.saini06@gmail.com>
Date: Sat, 20 Jul 2019 09:57:24 -0500
Subject: [PATCH] fixed race in consumer group example

---
 examples/consumergroup/main.go | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/examples/consumergroup/main.go b/examples/consumergroup/main.go
index 54db82b42..2c8eee52a 100644
--- a/examples/consumergroup/main.go
+++ b/examples/consumergroup/main.go
@@ -72,7 +72,7 @@ func main() {
 	 * Setup a new Sarama consumer group
 	 */
 	consumer := Consumer{
-		ready: make(chan bool, 0),
+		ready: make(chan bool),
 	}
 
 	ctx, cancel := context.WithCancel(context.Background())
@@ -82,8 +82,8 @@ func main() {
 	}
 
 	wg := &sync.WaitGroup{}
+	wg.Add(1)
 	go func() {
-		wg.Add(1)
 		defer wg.Done()
 		for {
 			if err := client.Consume(ctx, strings.Split(topics, ","), &consumer); err != nil {
@@ -93,7 +93,7 @@ func main() {
 			if ctx.Err() != nil {
 				return
 			}
-			consumer.ready = make(chan bool, 0)
+			consumer.ready = make(chan bool)
 		}
 	}()