Reduce the kafka message size limit more

0xProject · Oct 12, 2023 · 6643df4 · 6643df4
1 parent f1ee3c5
commit 6643df4
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 = 400000;
+    const MAX_SIZE = 100000;
 
     let currentSize = 0;
     let messages = [];