From 08cfb06dd1bcdf8b23c27ce9b240712decbe0906 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Juan=20Pablo=20Nore=C3=B1a-Monsalve?=
 <34222866+jpnorenam@users.noreply.github.com>
Date: Wed, 2 Jun 2021 16:19:22 -0500
Subject: [PATCH] update kafka write data chunk

---
 lib/nodes/kafka.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/lib/nodes/kafka.cpp b/lib/nodes/kafka.cpp
index 981f97bca..7eec833a8 100644
--- a/lib/nodes/kafka.cpp
+++ b/lib/nodes/kafka.cpp
@@ -549,7 +549,7 @@ int kafka_write(struct vnode *n, struct sample *smps[], unsigned cnt, unsigned *
 
 	size_t wbytes;
 
-	char data[1500];
+	char data[4096];
 
 	ret = io_sprint(&k->io, data, sizeof(data), &wbytes, smps, cnt);
 	if (ret < 0)