Skip to content
操作指南/开发示例/开发转换示例/对Kafka主题输入数据

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

对Kafka主题输入数据。

主要步骤如下:

模型

input

组件说明:

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

开发步骤

步骤1:生成记录

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

generate

步骤2:基础配置

配置数据源和主题名称。

config1config2

步骤3:运行结果

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

run

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

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

注意事项

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