普元数据开发平台 普元数据开发平台
产品介绍
安装部署
快速入门
操作指南
SDK开发指南
FAQ
  • Kafka输入
  • 模型
  • 开发步骤

# Kafka输入

kafka基本配置使用。

主要步骤如下:

  • 模型
  • 开发步骤
    • 组件页面

# 模型

input

# 开发步骤

《组件页面》

选择Kafka对应的数据源信息,配置topic以及消费组名称,下方可配置额外的连接信息。 input

以auto.offset.reset = latest(从分区的最新的记录开始消费,即从最新的offset开始消费) 为例:

对组件进行保存->提交->运行,此时kafka一直处于挂起状态,等待消息输入。

input

Kafka输出组件进行消息输入,配置参考Kafka输出组件配置,输出完毕之后Kafka输入组件则会接收到对应topic的信息。

input