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 (191, '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-purse-points-logs\\\"}\",\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\\\": \\\"实时计算通讯日志及联动值\\\",\\n      \\\"topic\\\": \\\"dispatch.binlog-cdc.topic.tencent_close_room_events\\\",\\n      \\\"apiDefinition\\\": {\\n        \\\"api\\\": \\\"https://v5qy.te.baibaodun.com.cn/dispatch/tencent/callback/calculate\\\",\\n        \\\"method\\\": \\\"POST\\\",\\n        \\\"isBodyCollection\\\": true,\\n        \\\"bodyJsonTemplate\\\": \\\"{\\\\\\\"ids\\\\\\\":[\\\\\\\"#{after.id}\\\\\\\"]}\\\",\\n        \\\"headerJsonTemplate\\\": \\\"{\\\\\\\"Content-Type\\\\\\\":\\\\\\\"application/json\\\\\\\"}\\\"\\n      }\\n    }\\n  ]\\n}\"\r\n}', 'flink从obpm2+baibaodunflow的binlog捕获数据推到kafka', 1, '2023-04-17 14:10:17', '2023-03-05 20:21:59', NULL, NULL, NULL, 'xxxx', 0);

nohup java -Xms1024m -Xmx1024m  -jar flink-data-webhook-task-3.2.jar te 191 purse-comm-logs &> flink-data-webhook-task-3.2-purse-comm-logs.log &