修改kafka连接

src/main/java/com/dsk/flink/dsc/utils/EtlUtils.java

@@ -16,14 +16,14 @@ 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", "1048576"); //1M
-        properties.setProperty("flink.consumer.max.fetch.size", "524288");//512k
-        properties.setProperty("session.timeout.ms", "30000");
+        properties.setProperty("fetch.max.bytes", "20971520"); //20M
+        properties.setProperty("flink.consumer.max.fetch.size", "20971520");//20M
+        properties.setProperty("session.timeout.ms", "60000");
         properties.setProperty("heartbeat.interval.ms", "10000");
-        properties.setProperty("request.timeout.ms", "60000");
+        properties.setProperty("request.timeout.ms", "120000");
         properties.setProperty("retries", "3");
         properties.setProperty("retry.backoff.ms", "5000");
-        properties.setProperty("receive.buffer.bytes", "65536"); //64k
+        properties.setProperty("receive.buffer.bytes", "2097152"); //2m
         properties.setProperty("max.poll.records", "10");
 
         return properties;