diff --git a/pkg/ingester-kafka/kafka/kafka_tee.go b/pkg/ingester-kafka/kafka/kafka_tee.go
index e21f2ff5a77a..6aeaad9724e6 100644
--- a/pkg/ingester-kafka/kafka/kafka_tee.go
+++ b/pkg/ingester-kafka/kafka/kafka_tee.go
@@ -101,7 +101,7 @@ func NewTee(
 		// When a Produce request to Kafka fail, the client will retry up until the RecordDeliveryTimeout is reached.
 		// Once the timeout is reached, the Produce request will fail and all other buffered requests in the client
 		// (for the same partition) will fail too. See kgo.RecordDeliveryTimeout() documentation for more info.
-		kgo.RecordRetries(math.MaxInt64),
+		kgo.RecordRetries(math.MaxInt),
 		kgo.RecordDeliveryTimeout(time.Minute),
 		kgo.ProduceRequestTimeout(time.Minute),
 		kgo.RequestTimeoutOverhead(time.Minute),