kafka panic: Check that error is non-nil before

fixes #1764
influxdata · Sep 14, 2016 · 828278d · 828278d
1 parent bc22309
commit 828278d
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/plugins/inputs/kafka_consumer/kafka_consumer.go b/plugins/inputs/kafka_consumer/kafka_consumer.go
@@ -128,7 +128,9 @@ func (k *Kafka) receiver() {
 		case <-k.done:
 			return
 		case err := <-k.errs:
-			log.Printf("Kafka Consumer Error: %s\n", err.Error())
+			if err != nil {
+				log.Printf("Kafka Consumer Error: %s\n", err)
+			}
 		case msg := <-k.in:
 			metrics, err := k.parser.Parse(msg.Value)
 			if err != nil {