diff --git a/examples/consumer_example/consumer_example.go b/examples/consumer_example/consumer_example.go
index <HASH>..<HASH> 100644
--- a/examples/consumer_example/consumer_example.go
+++ b/examples/consumer_example/consumer_example.go
@@ -39,8 +39,7 @@ func main() {
 	broker := os.Args[1]
 	group := os.Args[2]
 	topics := os.Args[3:]
-
-	sigchan := make(chan os.Signal)
+	sigchan := make(chan os.Signal, 1)
 	signal.Notify(sigchan, syscall.SIGINT, syscall.SIGTERM)
 
 	c, err := kafka.NewConsumer(&kafka.ConfigMap{
consumer_example: make term signal channel buffered to avoid select() miss