From 796e7ee0c69680dfda282ee2f0d959dadf808f31 Mon Sep 17 00:00:00 2001
From: Kim Tore Jensen <kimtjen@gmail.com>
Date: Tue, 1 Oct 2024 16:15:19 +0200
Subject: [PATCH] Fix failing tests

---
 internal/kafka/kafka.go | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/internal/kafka/kafka.go b/internal/kafka/kafka.go
index d54f7d0..f810e1f 100644
--- 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
 		}