feat: 缓存配置

deploy.sh

@@ -10,6 +10,7 @@ LOCAL_FS_ADMIN_JAR="./fs-admin/target/fs-admin.jar" # 假设target目录和你
 LOCAL_FS_COMPANY_JAR="./fs-company/target/fs-company.jar"
 LOCAL_FS_USER_APP_JAR="./fs-user-app/target/fs-user-app.jar"
 LOCAL_FS_API_JAR="./fs-api/target/fs-api.jar"
+LOCAL_FS_SYNC_JAR="./fs-sync/target/fs-sync-0.0.1-SNAPSHOT.jar"
 
 # 函数：检查本地文件是否存在
 check_local_file() {
@@ -24,6 +25,7 @@ check_local_file "$LOCAL_FS_ADMIN_JAR"
 check_local_file "$LOCAL_FS_COMPANY_JAR"
 check_local_file "$LOCAL_FS_USER_APP_JAR"
 check_local_file "$LOCAL_FS_API_JAR"
+check_local_file "$LOCAL_FS_SYNC_JAR"
 # 停止远程服务器上可能正在运行的旧版本（假设进程名与 JAR 包名相同）
 stop_remote_app() {
   local app_name=$1
@@ -52,7 +54,7 @@ deploy_jar() {
 # 主要部署流程
 
 # 部署 fs-admin
-deploy_jar "$LOCAL_FS_ADMIN_JAR" "fs-admin"
+#deploy_jar "$LOCAL_FS_ADMIN_JAR" "fs-admin"
 
 # 部署 fs-company
 #deploy_jar "$LOCAL_FS_COMPANY_JAR" "fs-company"
@@ -62,6 +64,7 @@ deploy_jar "$LOCAL_FS_ADMIN_JAR" "fs-admin"
 #deploy_jar "$LOCAL_FS_API_JAR" "fs-api"
 
 #deploy_jar "$LOCAL_FS_USER_APP_JAR" "fs-api"
+deploy_jar "$LOCAL_FS_SYNC_JAR" "fs-sync"
 
 echo "Deployment completed."
 

fs-sync/src/main/java/com/fs/fssync/listener/MySqlEventListener.java

@@ -40,7 +40,7 @@ public class MySqlEventListener implements CommandLineRunner {
     private FlinkConfig flinkConfig;
 
     private static final String JOB_ID = "1a2b3c4d5e6f7a8b9c0d1e2f3a4b5c6d";
-    private static final String CHECKPOINT_DIR = "file:///d:/data/flink/checkpoints";
+    private static final String CHECKPOINT_DIR = "file:///home/software/fs-sync/data/flink/checkpoints";
 
     @Override
     public void run(String... args) throws Exception {

fs-sync/src/main/resources/application.yml

@@ -7,16 +7,16 @@ logging:
 flink:
   cdc:
     mysql:
-      hostname: gz-cdb-of55khc9.sql.tencentcdb.com
-      port: 23620
-      databaseList: fs_hospital
+      hostname: 172.16.0.31
+      port: 3306
+      databaseList: fs_fhjx_hospital
       tableList:
-        - fs_hospital.fs_user
-        - fs_hospital.fs_store_product
-        - fs_hospital.fs_store_product_attr_value
-        - fs_hospital.fs_store_product_package
+        - fs_fhjx_hospital.fs_user
+        - fs_fhjx_hospital.fs_store_product
+        - fs_fhjx_hospital.fs_store_product_attr_value
+        - fs_fhjx_hospital.fs_store_product_package
       username: root
-      password: Rtyy_2023
+      password: Ylrz_1q2w3e4r5t6y
       serverTimeZone: Asia/Shanghai
       startupOptions: initial # 可选值: latest, initial, specificOffset, timestamp
   checkpoint: