数据流处理

任务列表

__菜单路径：__数据管理 → 数据流处理

__功能说明：__维护Kafka流式关联或归并去重任务，并查看运行状态。

__主要配置：__任务名称、处理类型、源Topic、目标Topic、Join类型、状态

__页面按钮：__创建任务、搜索、启动、停止、编辑、删除

操作步骤

进入数据流处理 → 搜索或创建任务 → 配置源和目标Topic → 保存 → 启动 → 在列表确认状态为运行中。

图 256　任务列表

创建与编辑任务

__菜单路径：__数据管理 → 数据流处理 → 创建任务/编辑

__功能说明：__配置Join关联或Dedup归并去重处理逻辑。运行中的任务需先停止后才能编辑。

__主要配置：__任务名称、处理类型、源Topic、目标Topic、关联字段、Join类型、去重字段、窗口参数

__页面按钮：__确定、取消、Join类型说明

操作步骤

点击创建任务 → 选择处理类型 → 填写Topic和处理参数 → 确定 → 启动；编辑时先停止任务，再修改并重新启动。

图 257　创建与编辑任务

使用示例

使用场景：需要创建一个从源 Topic 写入目标 Topic 的流处理任务。

进入【数据流处理】，点击【创建任务】。

填写任务名称、源 Topic、目标 Topic 和处理类型。

点击【保存】并启动，在列表中确认任务状态为运行中。