fix: change config gateway address to host

3 files changed, 17 insertions, 14 deletions

diff --git a/platform-etl/src/main/java/com/zdjizhi/etl/common/CommonConfig.java b/platform-etl/src/main/java/com/zdjizhi/etl/common/CommonConfig.java
index 5545c76..802ce97 100644
--- a/platform-etl/src/main/java/com/zdjizhi/etl/common/CommonConfig.java
+++ b/platform-etl/src/main/java/com/zdjizhi/etl/common/CommonConfig.java
@@ -25,7 +25,7 @@ public class CommonConfig {
             .stringType()
             .defaultValue("DHCP,DNS,FTP,GRE,GTP,HTTP,HTTPS,ICMP,IMAP,IMAPS,IPSEC,ISAKMP,XMPP,L2TP,LDAP,MMS,NETBIOS,NETFLOW,NTP,POP3,POP3S,RDP,PPTP,RADIUS,RTCP,RTP,RTSP,SIP,SMB,SMTP,SMTPS,SNMP,SSDP,SSH,SSL,STUN,TELNET,TFTP,OPENVPN,RTMP,TEREDO,FTPS,DTLS,SPDY,BJNP,QUIC,MDNS,Unknown TCP,Unknown UDP,Unknown Other,IKE,MAIL,SOCKS,DoH,SLP,SSL with ESNI,ISATAP,Stratum,SSL with ECH");
 
-    public static final ConfigOption<String> GATEWAY_ADDRESS = ConfigOptions.key("gateway.address")
+    public static final ConfigOption<String> GATEWAY_HOST = ConfigOptions.key("gateway.host")
             .stringType()
             .noDefaultValue();
     public static final ConfigOption<String> GATEWAY_PORT = ConfigOptions.key("gateway.port")
diff --git a/platform-etl/src/main/java/com/zdjizhi/etl/knowledge/MetadataListenerUtils.java b/platform-etl/src/main/java/com/zdjizhi/etl/knowledge/MetadataListenerUtils.java
index e2849c6..cf68d24 100644
--- a/platform-etl/src/main/java/com/zdjizhi/etl/knowledge/MetadataListenerUtils.java
+++ b/platform-etl/src/main/java/com/zdjizhi/etl/knowledge/MetadataListenerUtils.java
@@ -74,7 +74,7 @@ public class MetadataListenerUtils {
 
         private String getUrl() {
             return "http://"
-                    + configuration.get(CommonConfig.GATEWAY_ADDRESS)
+                    + configuration.get(CommonConfig.GATEWAY_HOST)
                     + ":"
                     + configuration.get(CommonConfig.GATEWAY_PORT)
                     + configuration.get(CommonConfig.KNOWLEDGE_PATH);
diff --git a/platform-schedule/src/main/resources/common.properties b/platform-schedule/src/main/resources/common.properties
index 335c9f8..34b0b71 100644
--- a/platform-schedule/src/main/resources/common.properties
+++ b/platform-schedule/src/main/resources/common.properties
@@ -1,31 +1,34 @@
 # ????
 stream.execution.job.name=ETL-METRIC
 # ?????
-stream.execution.environment.parallelism=2
+stream.execution.environment.parallelism=1
 # kafka source???
-session.record.completed.parallelism=2
+session.record.completed.parallelism=1
 # session-record-cn sink???
-cn.record.parallelism=2
+cn.record.parallelism=1
 # ???sink???
-metric.output.parallelism=2
+metric.output.parallelism=1
 # dns???sink???
-dns.metric.output.parallelism=2
+dns.metric.output.parallelism=1
 # ????sink???
-metric.entity.relation.output.parallelism=2
+metric.entity.relation.output.parallelism=1
 # ????sink???
-metric.dynamic.attribute.output.parallelism=2
-etl.topic=SESSION-RECORD
+metric.dynamic.attribute.output.parallelism=1
 # kafka???
-kafka.input.bootstrap.servers=192.168.44.12:9092
+kafka.input.bootstrap.servers=192.168.44.55:9092
 session.record.completed.topic=SESSION-RECORD
 session.record.completed.group.id=55-test
+# kafka???sasl?? 0:? 1:?
+input.sasl.jaas.config.flag=0
+# clickhouse
+clickhouse.address=192.168.44.55:9001
+clickhouse.user=default
+clickhouse.password=ceiec2019
 # kafka???
 kafka.output.bootstrap.servers=192.168.44.55:9092
 # SESSION-RECORD-CN??topic
 cn.record.topic=SESSION-RECORD-CN
 # kafka???sasl?? 0:? 1:?
-input.sasl.jaas.config.flag=0
-# kafka???sasl?? 0:? 1:?
 output.sasl.jaas.config.flag=0
 # flink checkpoint?? 0:? 1:?
 flink.enable.checkpoint.flag=1
@@ -34,4 +37,4 @@ nacos.server.addr=192.168.44.55:8848
 # api detection url
 rule.full.url=http://192.168.44.54:8090/v1/rule/detection
 rule.inc.url=http://192.168.44.54:8090/v1/rule/detection/increase
-gateway.address=192.168.44.55
\ No newline at end of file
+gateway.host=192.168.44.55
\ No newline at end of file