修改bug

b9829263 · liaowenwu · 27addb78 · b9829263
Commit b9829263 authored Dec 12, 2024 by liaowenwu
Hide whitespace changes
Inline Side-by-side

Showing with 4 additions and 0 deletions

EtlUtils.java src/main/java/com/dsk/flink/dsc/utils/EtlUtils.java +4 -0

No files found.
--- a/src/main/java/com/dsk/flink/dsc/utils/EtlUtils.java
+++ b/src/main/java/com/dsk/flink/dsc/utils/EtlUtils.java
@@ -16,6 +16,10 @@ public class EtlUtils {
        properties.setProperty("sasl.jaas.config", getSaslJaasConfig(username,password));
        properties.setProperty("security.protocol", "SASL_PLAINTEXT");
        properties.setProperty("sasl.mechanism", "SCRAM-SHA-512");
+        properties.setProperty("fetch.max.bytes", "2097152000");
+        properties.setProperty("max.partition.fetch.bytes", "2097152000");
+        properties.setProperty("flink.consumer.max.fetch.size", "2097152000");
+        properties.setProperty("frame.size", "2097152000");
        return properties;
    }