普元数据开发平台 普元数据开发平台
产品介绍
安装部署
快速入门
操作指南
SDK开发指南
FAQ
  • Kafka输入组件使用说明
  • 组件说明
  • 配置项说明

# Kafka输入组件使用说明

  • 组件说明
  • 配置项说明
  • 使用示例
    • kafka配置用例

# 组件说明

Kafka输入组件用于从 Apache Kafka 数据库中读取数据。

# 配置项说明

配置名称 数据类型 是否必须 默认值 描述
节点名称 String 是 - 当前创建的节点名称,由用户自定义且不可为空。命名可包含字母、数字、下划线。
选择数据源 String 是 - 当前输入绑定的数据源名称,从下拉选项中列出的指定的关联类型(Kafka)的数据源进行选择。
topic String 是 - Kafka 主题名称。
消费组名称 String 是 - Kafka 消费组名称 。
超时时间(ms) Integer 是 300000 读取超时时间。
启用超时终止 Boolean 是 false 超时终止的开关。如果启用则超时后会终止运行。
字段名称 String 是 KafkaMessageName 要读取的字段名称。
键值 String 是 - 通过键值设置更多的参数。

← JSON输入 StarRocks输入 →