INSERT INTO `obpm2`.`flink_jobs`(`id`, `name`, `job_type`, `parameter_json`, `description`, `is_online`, `last_updated_time`, `created_time`, `flink_job_id`, `flink_job_started_time`, `flink_job_started_response`, `title`, `is_deleted`) VALUES (189, 'WebHookAPI演示-企业-驻勤-驻勤人员', 2, '{\r\n  \"param1\": \"{\\\"job.name\\\":\\\"简化版本-CheckPoint-更新企业和驻勤点-驻勤人员信息-3.0\\\",\\\"checkpoint.mode\\\":\\\"file\\\",\\\"checkpoint.hdfs.config\\\":\\\"core-site-default.xml\\\",\\\"checkpoint.disk.location\\\":\\\"/tmp/cp-webhook-company-station-person\\\"}\",\r\n  \"param2\": \"{\\n  \\\"name\\\": \\\"WebHookAPI演示-企业-驻勤-驻勤人员\\\",\\n  \\\"topicDefinition\\\": {\\n    \\\"name\\\": \\\"cp-dispatch\\\",\\n    \\\"topic\\\": \\\"\\\",\\n    \\\"consumerGroupId\\\": \\\"dispatch.webhook.api\\\",\\n    \\\"enableAutoCommit\\\": true,\\n    \\\"scanStartupMode\\\": \\\"group-offsets\\\",\\n    \\\"primaryKeyName\\\": \\\"ID\\\",\\n    \\\"autoOffsetRest\\\": \\\"earliest\\\",\\n    \\\"bootstrapServer\\\": \\\"117.78.39.204:9092\\\"\\n  },\\n  \\\"webHookConfigs\\\": [\\n    {\\n      \\\"title\\\": \\\"同步企业信息到RedisJson\\\",\\n      \\\"topic\\\": \\\"dispatch.binlog-cdc.topic.rd_company_summary\\\",\\n      \\\"apiDefinition\\\": {\\n        \\\"api\\\": \\\"https://v5qy.te.baibaodun.com.cn/dispatch/flush/request\\\",\\n        \\\"method\\\": \\\"POST\\\",\\n        \\\"isBodyCollection\\\": true,\\n        \\\"bodyJsonTemplate\\\": \\\"{\\\\\\\"contents\\\\\\\":[{\\\\\\\"ids\\\\\\\":[\\\\\\\"#{after.id}\\\\\\\"],\\\\\\\"dataType\\\\\\\":\\\\\\\"Company\\\\\\\"}]}\\\",\\n        \\\"headerJsonTemplate\\\": \\\"{\\\\\\\"Content-Type\\\\\\\":\\\\\\\"application/json\\\\\\\"}\\\"\\n      }\\n    },\\n    {\\n      \\\"title\\\": \\\"同步驻勤点信息到RedisJson\\\",\\n      \\\"topic\\\": \\\"dispatch.binlog-cdc.topic.rd_security_station_summary\\\",\\n      \\\"apiDefinition\\\": {\\n        \\\"api\\\": \\\"https://v5qy.te.baibaodun.com.cn/dispatch/flush/request\\\",\\n        \\\"method\\\": \\\"POST\\\",\\n        \\\"isBodyCollection\\\": true,\\n        \\\"bodyJsonTemplate\\\": \\\"{\\\\\\\"contents\\\\\\\":[{\\\\\\\"ids\\\\\\\":[\\\\\\\"#{after.id}\\\\\\\"],\\\\\\\"dataType\\\\\\\":\\\\\\\"Station\\\\\\\"}]}\\\",\\n        \\\"headerJsonTemplate\\\": \\\"{\\\\\\\"Content-Type\\\\\\\":\\\\\\\"application/json\\\\\\\"}\\\"\\n      }\\n    },\\n    {\\n      \\\"title\\\": \\\"同步驻勤人员信息\\\",\\n      \\\"topic\\\": \\\"dispatch.binlog-cdc.topic.rd_security_station_person_summary\\\",\\n      \\\"apiDefinition\\\": {\\n        \\\"api\\\": \\\"https://v5qy.te.baibaodun.com.cn/dispatch/flush/request\\\",\\n        \\\"method\\\": \\\"POST\\\",\\n        \\\"isBodyCollection\\\": true,\\n        \\\"bodyJsonTemplate\\\": \\\"{\\\\\\\"contents\\\\\\\":[{\\\\\\\"stationPersonRequest\\\\\\\":{\\\\n          \\\\\\\"stationIds\\\\\\\":[\\\\\\\"#{after.id}\\\\\\\"],\\\\\\\"employeeIds\\\\\\\":[\\\\\\\"#{after.id}\\\\\\\"]\\\\n        },\\\\\\\"dataType\\\\\\\":\\\\\\\"Station\\\\\\\"}]}\\\",\\n        \\\"headerJsonTemplate\\\": \\\"{\\\\\\\"Content-Type\\\\\\\":\\\\\\\"application/json\\\\\\\"}\\\"\\n      }\\n    }\\n  ]\\n}\"\r\n}', 'flink从obpm2+baibaodunflow的binlog捕获数据推到kafka', 1, '2023-04-17 14:07:50', '2023-03-05 20:21:59', NULL, NULL, NULL, 'xxxx', 0);



nohup java -Xms1024m -Xmx1024m  -jar flink-data-webhook-task-3.2.jar te 189 company-station-person&> flink-data-webhook-task-3.2-company-station-person.log &