diff --git a/kafka/kafka.go b/kafka/kafka.go
index 701c1dd..e78f768 100644
--- a/kafka/kafka.go
+++ b/kafka/kafka.go
@@ -196,8 +196,8 @@ func (k *Kafka) NewWriter(topic string) (*kafka.Writer, error) {
 		Topic:       topic,
 		Balancer:    &kafka.LeastBytes{},
 		BatchSize:   2000,
-		Compression: kafka.Snappy,
-		Logger:      k.l,
+		Compression: kafka.Lz4,
+		// Logger:      k.l,
 		ErrorLogger: k.l,
 	}