From be5c7745da5512a5427a549c4b44447e25b6edb1 Mon Sep 17 00:00:00 2001 From: Ashwanth Goli Date: Mon, 2 Sep 2024 10:40:11 +0530 Subject: [PATCH] chore(ci): fix failing arm builds --- pkg/ingester-kafka/kafka/kafka_tee.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) 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),