diff --git a/pkg/kafka/writer_client.go b/pkg/kafka/writer_client.go
index bb6fbb8082..8f65679c01 100644
--- a/pkg/kafka/writer_client.go
+++ b/pkg/kafka/writer_client.go
@@ -68,7 +68,7 @@ func NewWriterClient(kafkaCfg Config, maxInflightProduceRequests int, logger log
 		// 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(kafkaCfg.WriteTimeout),
 		kgo.ProduceRequestTimeout(kafkaCfg.WriteTimeout),
 		kgo.RequestTimeoutOverhead(writerRequestTimeoutOverhead),