flink-streaming-computing-task 应用的参数
"{
   \"job.name\":\"consume kafka to build data summary kms team\",
   \"checkpoint.mode\":\"file\",
   \"checkpoint.disk.location\":\"/data/soft/flink/config/kms_team/cdc-kafka-cosumer\",
   \"checkpoint.hdfs.config\":\"core-site-default.xml\"
}" "{\"id\": \"job-kafka-jdbc-tenant-users-01-events-tenant_users\",  \"name\": \"tenant-tenant_users-table\",  \"description\": \"extract tenant users from kafka to summary table\",  \"kafkaDefinition\": {    \"name\": \"kafka..\",
                    \"bootstrapServer\": \"43.155.113.170:9092\",
                    \"topic\": \"obpm2.cdc.topic.events.tenant_users\",
                    \"consumerGroupId\": \"data.collector.group.tenant_users.consumer\",
                   \"autoOffsetRest\": \"earliest\",
                   \"scanStartupMode\": \"group-offsets\",
                   \"enableAutoCommit\": \"true\",
                    \"primaryKeyName\":\"ID\"
                  },
                  \"jdbcDefinition\": {
                    \"url\": \"jdbc:mysql://49.4.21.141:3306/securityflow?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8\",
                    \"username\": \"TL5_enterprise\",
                    \"password\": \"Bcx#20221024\",
                    \"connectionTimeZone\": \"GMT-8\",
                    \"driver\": \"com.mysql.cj.jdbc.Driver\",
                    \"sqlTemplate\": \"INSERT INTO `securityflow`.`tlk_securityman_summary`(`PARENT`, `LASTMODIFIED`, `FORMNAME`, `DOMAINID`, `ITEM_pirture`,`ITEM_userID`, `ITEM_securityName`, `ITEM_DeptName`, `ITEM_DeptID`, `ID`, `ITEM_leaveDate`, `ITEM_companyName`, `ITEM_insure`)VALUES (NULL, NULL, NULL, NULL, NULL, :after.id, :after.name, :after.name, :after.id, :after.id, CURRENT_DATE(), :after.education, 1) ON DUPLICATE KEY UPDATE ITEM_securityName=:after.name,ITEM_companyName=:after.education\"
                  }
                }"


flink-cdc-kafka-source-task.JdbcBinLogCaptureApp
{
    "name":"Jdbc Binlog cdc to kafka",
    "jobType":"CDC_BINLOG",
    "description":"flink从binlog捕获数据推到kafka",
    "isOnline":true,
    "param1":{
        "job.name":"Jdbc Binlog cdc to kafka",
        "checkpoint.mode":"file",
        "checkpoint.disk.location":"/data/soft/flink/config/kms_team/binlog2Kafka_kms_team",
        "checkpoint.hdfs.config":"core-site-default.xml",
        "kafka.bootstrap.server":"43.155.113.170:9092",
        "kafka.cdc.topic.prefix":"[dbName].cdc.topic.events.[tableName]",
        "kafka.consumer.group.id":"cdc-binlog-flink-consumer-events"
        },
    "param2":{
        "source.name":"mysql-cdc-flink-source",
        "source.database.host":"49.4.21.141",
        "source.database.port":"2111",
        "source.database.username":"bcx",
        "source.database.password":"Wstestv5qy#2022",
        "source.database.connectionTimeZone":"GMT+8",
        "source.database.serverId":"6001-6200",
        "source.database.connectTimeout":"60000",
        "source.database.db.list":"obpm2;baibaodunflow;",
        "source.database.table.list":"obpm2.tenant_users;obpm2.tenant_employees;obpm2.tenant_organizations;obpm2.tenant_departments;baibaodunflow.TLK_COMPANYINFORMATION;baibaodunflow.TLK_ATTENDANCE_SITE_BASE_INFO;"
        }
}