Merge pull request #1991 from influxdata/noreqsize
fix: Remove bad max.request.size config parampull/24376/head
commit
d6885760d8
|
@ -126,7 +126,6 @@ impl KafkaBufferProducer {
|
|||
let mut cfg = ClientConfig::new();
|
||||
cfg.set("bootstrap.servers", &conn);
|
||||
cfg.set("message.timeout.ms", "5000");
|
||||
cfg.set("max.request.size", "10000000");
|
||||
|
||||
let producer: FutureProducer = cfg.create()?;
|
||||
|
||||
|
|
Loading…
Reference in New Issue