kafka: switch to lz4 compression; disable default logger on writer

2023-07-08 13:08:52 -07:00 · 2023-07-08 13:08:52 -07:00 · 7ad495fe2b
commit 7ad495fe2b
parent 3ba8ba4a22
1 changed files with 2 additions and 2 deletions
--- 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,
 	}