{
  "name": "Consume kafka to build rd_security_service_station_summary-v2.5",
  "jobType": "STREAMING_COMPUTED",
  "description": "flink从kafka消费数据并汇总数据到rd_security_service_station_summary",
  "isOnline": true,
  "param1": {
    "job.name": "Consume kafka(tlk_attendance_site_base_info) to build proc_rd_security_service_station_summary-2.5",
    "checkpoint.mode": "file",
    "checkpoint.disk.location": "/data/soft/flink/config/kms_team/cdc-kafka-cosumer",
    "checkpoint.hdfs.config": "core-site-default.xml"
  },
  "param2": {
    "id": "job-kafka-jdbc-baibaodunflow-events-tlk_attendance_site_base_info",
    "name": "baibaodunflow-tlk_companyinformation-table",
    "description": "extract baibaodunflow from kafka to proc_rd_security_service_station_summary table",
    "kafka2JdbcDefinitions": [
      {
        "name":"消费tlk_attendance_site_base_info事件消息到proc_rd_security_service_station_summary",
        "kafkaDefinition": {
          "name": "消费kafka:obpm2.binlog-cdc.topic.events-2.tlk_attendance_site_base_info",
          "bootstrapServer": "43.155.113.170:9092",
          "topic": "baibaodunflow.binlog-cdc.topic.events-2.tlk_attendance_site_base_info",
          "consumerGroupId": "data.collector.group.tlk_attendance_site_base_info.binlog-cdc-02",
          "autoOffsetRest": "earliest",
          "scanStartupMode": "group-offsets",
          "enableAutoCommit": "true",
          "primaryKeyName": "ID"
        },
        "jdbcDefinitions": [
          {
            "name":"执行proc_rd_employee_summary存储过程: 归集驻勤信息",
            "url": "jdbc:mysql://49.4.21.141:45611/securityflow?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8",
            "username": "bcx",
            "password": "Wstestv5qy#2022",
            "connectionTimeZone": "GMT-8",
            "driver": "com.mysql.cj.jdbc.Driver",
            "sqlTemplate": "call securityflow.proc_rd_security_service_station_summary(:after.ID,:after.ITEM_ATTENDANCESITENAME,:after.DOMAINID,:after.ITEM_PRINCIPALNAME,:after.ITEM_PRINCIPALPHONENO,:after.ITEM_ATTENDANCESITEFULLADDRESS,:after.ITEM_ATTENDANCESITETYPE,:after.ITEM_SERVEOBJECTTYPE,:after.ITEM_ATTENDANCESITELONGITUDE,:after.ITEM_ATTENDANCESITELATITUDE,:after.ITEM_CONTRACTSTARTDATE,:after.ITEM_CONTRACTENDDATE,:after.LASTMODIFIED)"
          }
        ]
      }
    ]
  }
}