普元数据开发平台 普元数据开发平台
产品介绍
安装部署
快速入门
操作指南
应用集成
运维指南
  • Kafka输出-对Kafka主题输入数据
  • 模型
  • 开发步骤
  • 注意事项

# Kafka输出-对Kafka主题输入数据

对Kafka主题输入数据。

主要步骤如下:

  • 模型
  • 开发步骤
    • 生成记录
    • 基础配置
    • 运行结果

# 模型

input

组件说明:

  • 生成记录:作为数据源,模拟输入数据
  • Kafka 输出:配置 Kafka 连接和输出主题

# 开发步骤

# 步骤1:生成记录

从「输入」分组拖出「生成记录」组件,配置模拟数据。

generate

# 步骤2:基础配置

配置数据源和主题名称。

config1 config2

# 步骤3:运行结果

对组件进行「保存」→「提交」→「运行」,日志如下代表运行成功。

run

验证:使用 Kafka 消费者工具验证数据是否成功写入主题。

具体测试方案请跳转 Kafka 输入组件配置。

# 注意事项

  • 确保 Kafka 集群可达
  • 目标主题需存在或配置自动创建
  • 序列化方式需与消费者端一致
  • 大数据量输出时注意配置批处理参数

← 关系型数据库到Doris数据库数据同步 修饰符更新使用 →