From 670cce70ca8da987844a9d5d248a05b87bcfdba7 Mon Sep 17 00:00:00 2001 From: "Grot (@grafanabot)" <43478413+grafanabot@users.noreply.github.com> Date: Mon, 2 Sep 2024 06:56:44 +0100 Subject: [PATCH] chore: [k218] chore(ci): fix failing arm builds (#14023) Co-authored-by: Ashwanth --- 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),