From 7ad495fe2bfb0cc719e34fbd79841b475e38485a Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Ask=20Bj=C3=B8rn=20Hansen?= <ask@develooper.com>
Date: Sat, 8 Jul 2023 13:08:52 -0700
Subject: [PATCH] kafka: switch to lz4 compression; disable default logger on
 writer

---
 kafka/kafka.go | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

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,
 	}