Fix failing tests

nais · Oct 1, 2024 · 796e7ee · 796e7ee
1 parent 8f20974
commit 796e7ee
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/internal/kafka/kafka.go b/internal/kafka/kafka.go
@@ -110,7 +110,7 @@ func (k *Kafka) Handler() func(http.ResponseWriter, *http.Request) {
 
 		c, err := consumer.ConsumePartition(k.topic, p, o)
 		if err != nil {
-			log.Errorf("could not consume partition (%s) from topic (%s): %s", p, k.topic, err)
+			log.Errorf("could not consume partition (%d) from topic (%s): %s", p, k.topic, err)
 			w.WriteHeader(http.StatusInternalServerError)
 			return
 		}