Merge pull request #12 from zr-hebo/kafka-compress

Kafka compress support
2019-12-19 10:11:53 +08:00 · 2019-12-19 10:11:53 +08:00 · 7952d1339f
parent e5d9649827 e68e06ec81
commit 7952d1339f
1 changed files with 1 additions and 1 deletions
--- a/exporter/kafka.go
+++ b/exporter/kafka.go
@ -54,7 +54,7 @@ func checkParams()  {
 	case "lz4":
 		compressType = sarama.CompressionLZ4
 	default:
-		panic(fmt.Sprintf("cannot support compress type: %s", compress))
+		panic(fmt.Sprintf("cannot support kafka compress type: %s", compress))
 	}

 	fmt.Printf("kafka message compress type: %s", compress)