fix

apache · Jan 9, 2025 · f5925de · f5925de
1 parent 81ccb30
commit f5925de
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...urce/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaProducerCluster.java b/...urce/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaProducerCluster.java
@@ -63,7 +63,7 @@ public class KafkaProducerCluster implements LifecycleAware {
 
     private KafkaProducer<String, byte[]> producer;
 
-    private long configuredMaxPayloadSize;
+    private long configuredMaxPayloadSize = 8388608L;
 
     public KafkaProducerCluster(
             String workerName,