From f5925de09d17d7198823e7b3a26f00cf8efe245c Mon Sep 17 00:00:00 2001
From: vernedeng <vernedeng@apache.org>
Date: Thu, 9 Jan 2025 20:14:07 +0800
Subject: [PATCH] fix

---
 .../inlong/sort/standalone/sink/kafka/KafkaProducerCluster.java | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaProducerCluster.java b/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaProducerCluster.java
index f2651a7b5a..5b4f2f9050 100644
--- a/inlong-sort-standalone/sort-standalone-source/src/main/java/org/apache/inlong/sort/standalone/sink/kafka/KafkaProducerCluster.java
+++ b/inlong-sort-standalone/sort-standalone-source/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,