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.Lz4,
-		// Logger:      k.l,
+		Compression: kafka.Snappy,
+		Logger:      k.l,
 		ErrorLogger: k.l,
 	}
 

version/version.go

@@ -84,11 +84,10 @@ func RegisterMetric(registry prometheus.Registerer) {
 			Name: "build_info",
 			Help: "Build information",
 		},
-		[]string{"version", "build"},
+		[]string{"version"},
 	)
 	registry.MustRegister(buildInfo)
-	info := VersionInfo()
-	buildInfo.WithLabelValues(fmt.Sprintf("%s/%s", info.Version, info.GitRev), info.BuildTime).Set(1)
+	buildInfo.WithLabelValues(Version()).Set(1)
 }
 
 var v string