Fix max open requests to one if idempotent writes is set to true (#8954)

This commit is contained in:
Helen Weller 2021-03-08 11:38:35 -05:00 committed by GitHub
parent d7df2c546b
commit 372004a993
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 3 additions and 0 deletions

View File

@ -38,6 +38,9 @@ func (k *WriteConfig) SetConfig(config *sarama.Config) error {
config.Producer.MaxMessageBytes = k.MaxMessageBytes
}
config.Producer.RequiredAcks = sarama.RequiredAcks(k.RequiredAcks)
if config.Producer.Idempotent {
config.Net.MaxOpenRequests = 1
}
return k.Config.SetConfig(config)
}