From 47e4e942957a958868690890d69ca0662c3866f7 Mon Sep 17 00:00:00 2001 From: Cyril Tovena Date: Wed, 11 Sep 2024 12:18:43 +0200 Subject: [PATCH] fix(kafka): Fixes writer initialization for arm32 --- pkg/kafka/writer_client.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/pkg/kafka/writer_client.go b/pkg/kafka/writer_client.go index bb6fbb8082c53..8f65679c01c17 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),