Flink Kafka 双写任务生成

按下面流程执行，默认服务对象是 bethune 仓库中的 Kafka 日志监控任务。

先做什么

先确认用户给了哪些输入。若信息不全，只问最小必需项：

• 任务编号
• 参考任务，若用户说“参考任务34”则优先复用 34 的骨架
• Kafka topic
• module 过滤值
• 目标表名或业务名
• 消息字段结构，尤其是是否存在嵌套对象或列表展开字段

若用户已经给出“按任务34类似模式”，默认理解为：