Merge pull request #1 from JacksonJia/master

Disable compression
lingmiaotech · Feb 7, 2018 · 13f38ba · 13f38ba
2 parents 676bf87 + f8367c8
commit 13f38ba
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/kafka/kafka.go b/kafka/kafka.go
@@ -27,7 +27,7 @@ func InitKafka() (err error) {
 
 	configs := sarama.NewConfig()
 	configs.Producer.RequiredAcks = sarama.WaitForLocal       // Only wait for the leader to ack
-	configs.Producer.Compression = sarama.CompressionSnappy   // Compress messages
+	configs.Producer.Compression = sarama.CompressionNone     // Compress messages
 	configs.Producer.Flush.Frequency = 500 * time.Millisecond // Flush batches every 500ms
 	configs.Producer.Retry.Max = 3
 	configs.Producer.Return.Errors = true