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 (190, '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-employee\\\"}\",\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_employee_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\\\\\\\":\\\\\\\"Employee\\\\\\\"}]}\\\",\\n        \\\"headerJsonTemplate\\\": \\\"{\\\\\\\"Content-Type\\\\\\\":\\\\\\\"application/json\\\\\\\"}\\\"\\n      }\\n    }\\n  ]\\n}\"\r\n}', 'flink从obpm2+baibaodunflow的binlog捕获数据推到kafka', 1, '2023-04-17 14:08:49', '2023-03-05 20:21:59', NULL, NULL, NULL, 'xxxx', 0);

nohup java -Xms2048m -Xmx2048m  -jar flink-data-webhook-task-3.2.jar te 190 employee &> flink-data-webhook-task-3.2-employee.log &