{
  "id": "job000001",
  "name": "tenant-summary-table",
  "description": "extract tenant users from kafka to summary table",
  "kafkaDefinition": {
    "sourceConnector": {
      "name": "kafka..",
      "bootstrapServer": "43.155.113.170:9092",
      "topic": "streaming.topic.data.obpm2.tenant_users",
      "consumerGroupId": "kafka-streaming-consumer1-2-06",
      "autoOffsetRest": "earliest",
      "scanStartupMode": "group-offsets",
      "enableAutoCommit": "true"
    },
    "definitionSqls": [
      "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)"
    ]
  },
  "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"
      },
      "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"
      },
      "definitionSql": "CREATE TABLE baibaodunflow_test_tlk_securityman(id STRING,name STRING, hired_date STRING,leave_time STRING,status integer, PRIMARY KEY (id) NOT ENFORCED)"
    }
  ],
  "executeSql": "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 left join obpm2_tenant_employees y on x.id=y.tenant_user_id"
}