diff --git a/src/utils/kafka_send.ts b/src/utils/kafka_send.ts
index a1119948..41c31e8f 100644
--- a/src/utils/kafka_send.ts
+++ b/src/utils/kafka_send.ts
@@ -33,7 +33,7 @@ export async function kafkaSendRawAsync(
     keyFields: string[],
     payload: any[],
 ): Promise<void> {
-    const MAX_SIZE = 500000; // 1MB
+    const MAX_SIZE = 400000;
 
     let currentSize = 0;
     let messages = [];