apitech
/
loki
mirror of https://github.com/grafana/loki
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

fix(kafka): Fixes writer initialization for arm32 (#14115)

Browse Source
pull/14112/head^2
Cyril Tovena 8 months ago committed by GitHub
parent 8307c42c54
commit 4da035b6b7
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 1 additions and 1 deletions
Show all changes Ignore whitespace when comparing lines Ignore changes in amount of whitespace Ignore changes in whitespace at EOL
Show Stats Download Patch File Download Diff File
  1. 2
      pkg/kafka/writer_client.go

2
pkg/kafka/writer_client.go
Unescape View File

@ -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),

Write Preview
Loading…
Cancel
Save