Reduce the kafka message size limit

0xProject · Oct 12, 2023 · f1ee3c5 · f1ee3c5
1 parent 2676e6d
commit f1ee3c5
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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 = [];