{
  "id": "job000001",
  "name": "tenant-summary-table",
  "description": "extract tenant users from kafka to summary table",
  "kafkaDefinitions": [
    {
      "sourceConnector": {
        "name": "kafka-tenant-users",
        "bootstrapServer": "43.155.113.170:9092",
        "topic": "streaming.topic.data.obpm2.tenant_users",
        "consumerGroupId": "kafka-streaming-consumer1-2-09",
        "autoOffsetRest": "earliest",
        "scanStartupMode": "latest-offset",
        "enableAutoCommit": "true"
      },
      "definitionSql": "CREATE TABLE kafka_consumer_tenant_users(id STRING, name STRING, telephone STRING, place_of_now_address STRING, third_party_login_no STRING, last_sync_time STRING, PRIMARY KEY (id) NOT ENFORCED)"
    },
    {
      "sourceConnector": {
        "name": "kafka-tenant-employees",
        "bootstrapServer": "43.155.113.170:9092",
        "topic": "streaming.topic.data.obpm2.tenant_employees",
        "consumerGroupId": "kafka-streaming-consumer1-2-09",
        "autoOffsetRest": "earliest",
        "scanStartupMode": "latest-offset",
        "enableAutoCommit": "true"
      },
      "definitionSql": "CREATE TABLE kafka_consumer_tenant_employees(id STRING,created_time string,hired_date string,leave_time string,status integer,tenant_user_id STRING, PRIMARY KEY (id) NOT ENFORCED)"
    }
  ],
  "jdbcDefinitions": [
    {
      "connector": {
        "url": "jdbc:mysql://49.4.21.141:45611/obpm2?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8",
        "username": "bcx",
        "password": "Wstestv5qy#2022",
        "tableName": "tenant_employees",
        "connectionTimeZone": "GMT-8",
        "driver": "com.mysql.cj.jdbc.Driver"
      },
      "definitionSql": "CREATE TABLE obpm2_tenant_employees(id STRING,created_time string ,hired_date string,leave_time string,status integer,tenant_user_id STRING, PRIMARY KEY (id) NOT ENFORCED)"
    },
    {
      "connector": {
        "url": "jdbc:mysql://49.4.21.141:45611/baibaodunflow?characterEncoding=UTF-8&connectionTimeZone=GMT%2B8",
        "username": "bcx",
        "password": "Wstestv5qy#2022",
        "tableName": "test_tlk_securityman",
        "connectionTimeZone": "GMT-8",
        "driver": "com.mysql.cj.jdbc.Driver"
      },
      "definitionSql": "CREATE TABLE baibaodunflow_test_tlk_securityman(id STRING,name STRING, hired_date STRING,leave_time STRING,status integer, PRIMARY KEY (id) NOT ENFORCED)"
    }
  ],
  "batchSql": "EXECUTE STATEMENT SET BEGIN INSERT INTO baibaodunflow_test_tlk_securityman select y.id,x.name,y.hired_date,y.leave_time,y.status from kafka_consumer_tenant_users x join kafka_consumer_tenant_employees y on x.id=y.tenant_user_id; END;",
  "insertSql": "INSERT INTO baibaodunflow_test_tlk_securityman values('#{id}','#{name}','#{hired_date}','#{leave_time}','#{status}')",
  "updateSql": "UPDATE baibaodunflow_test_tlk_securityman set name='#{name}',hired_date='#{hired_date}',leave_time='#{leave_time}',status='#{status}' where id='#{id}'",
  "deleteSql": "DELETE FROM baibaodunflow_test_tlk_securityman WHERE id='#{id}'"
}