fix collector panic due to sarama sdk

Signed-off-by: luhualin <[email protected]>
jaegertracing · Nov 26, 2020 · 594f7f6 · 594f7f6
1 parent b8ccf73
commit 594f7f6
Showing 1 changed file with 4 additions and 2 deletions.
diff --git a/plugin/storage/kafka/writer.go b/plugin/storage/kafka/writer.go
@@ -57,8 +57,10 @@ func NewSpanWriter(
 	}()
 	go func() {
 		for e := range producer.Errors() {
-			logger.Error(e.Err.Error())
-			writeMetrics.SpansWrittenFailure.Inc(1)
+			if e != nil && e.Err != nil {
+				logger.Error(e.Err.Error())
+				writeMetrics.SpansWrittenFailure.Inc(1)
+			}
 		}
 	}()