We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent 8307c42 commit 4da035bCopy full SHA for 4da035b
pkg/kafka/writer_client.go
@@ -68,7 +68,7 @@ func NewWriterClient(kafkaCfg Config, maxInflightProduceRequests int, logger log
68
// When a Produce request to Kafka fail, the client will retry up until the RecordDeliveryTimeout is reached.
69
// Once the timeout is reached, the Produce request will fail and all other buffered requests in the client
70
// (for the same partition) will fail too. See kgo.RecordDeliveryTimeout() documentation for more info.
71
- kgo.RecordRetries(math.MaxInt64),
+ kgo.RecordRetries(math.MaxInt),
72
kgo.RecordDeliveryTimeout(kafkaCfg.WriteTimeout),
73
kgo.ProduceRequestTimeout(kafkaCfg.WriteTimeout),
74
kgo.RequestTimeoutOverhead(writerRequestTimeoutOverhead),
0 commit comments