Add message 'max_bytes' configuration (#4537)
This commit is contained in:
parent
2395413cc8
commit
61513c64b8
|
@ -37,6 +37,8 @@ type (
|
|||
RequiredAcks int
|
||||
// MaxRetry Tag
|
||||
MaxRetry int
|
||||
// Max Message Bytes
|
||||
MaxMessageBytes int
|
||||
|
||||
Version string `toml:"version"`
|
||||
|
||||
|
@ -140,6 +142,9 @@ var sampleConfig = `
|
|||
## until the next flush.
|
||||
# max_retry = 3
|
||||
|
||||
## Max message bytes, should be lower than server message.max.bytes config
|
||||
# MaxMessageBytes = 0
|
||||
|
||||
## Optional TLS Config
|
||||
# tls_ca = "/etc/telegraf/ca.pem"
|
||||
# tls_cert = "/etc/telegraf/cert.pem"
|
||||
|
@ -218,6 +223,10 @@ func (k *Kafka) Connect() error {
|
|||
config.Producer.Retry.Max = k.MaxRetry
|
||||
config.Producer.Return.Successes = true
|
||||
|
||||
if k.MaxMessageBytes > 0 {
|
||||
config.Producer.MaxMessageBytes = k.MaxMessageBytes
|
||||
}
|
||||
|
||||
// Legacy support ssl config
|
||||
if k.Certificate != "" {
|
||||
k.TLSCert = k.Certificate
|
||||
|
|
Loading…
Reference in New Issue