From 8d23dd6d6d5797809a1184ea378e4500c038c6ad Mon Sep 17 00:00:00 2001
From: Marko Mikulicic <mkm@influxdata.com>
Date: Wed, 14 Jul 2021 14:46:49 +0200
Subject: [PATCH] fix: Set kafka max message size in client

---
 write_buffer/src/kafka.rs | 1 +
 1 file changed, 1 insertion(+)

diff --git a/write_buffer/src/kafka.rs b/write_buffer/src/kafka.rs
index f01729a500..2f26436f66 100644
--- a/write_buffer/src/kafka.rs
+++ b/write_buffer/src/kafka.rs
@@ -68,6 +68,7 @@ impl KafkaBufferProducer {
         let mut cfg = ClientConfig::new();
         cfg.set("bootstrap.servers", &conn);
         cfg.set("message.timeout.ms", "5000");
+        cfg.set("message.max.bytes", "10000000");
 
         let producer: FutureProducer = cfg.create()?;