[INLONG-9120][Agent] Add offset db to store the offset data

justinwwhuang · Oct 26, 2023 · 8121b94 · 8121b94
1 parent 0875eef
commit 8121b94
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...ng-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/CommonConstants.java b/...ng-agent/agent-common/src/main/java/org/apache/inlong/agent/constant/CommonConstants.java
@@ -62,7 +62,7 @@ public class CommonConstants {
     public static final String PROXY_SEND_PARTITION_KEY = "proxy.partitionKey";
 
     // max size of single batch in bytes, default is 500KB
-    public static final int DEFAULT_PROXY_PACKAGE_MAX_SIZE = 500000;
+    public static final int DEFAULT_PROXY_PACKAGE_MAX_SIZE = 500 * 1024;
 
     public static final String PROXY_INLONG_STREAM_ID_QUEUE_MAX_NUMBER = "proxy.group.queue.maxNumber";
     public static final int DEFAULT_PROXY_INLONG_STREAM_ID_QUEUE_MAX_NUMBER = 10000;