记录注射
组件介绍
记录注射 组件是为那些正在开发特殊用途的转换，并希望使用 Java 将行注入到转换中的人创建的。或者从流输入转换（如 Kafka Consumer 转换）中注入行。
- 输入：
- 输出：
组件图标
页面介绍
记录注射 组件的配置页面如下图所示：
参数选项
记录注射 组件主要包括如下参数：
| 选项 | 说明 | 样例值 |
|---|---|---|
| 步骤名称 | 在画布上指定该步骤的唯一名称。 | |
| 字段名称 | 指定注入行的字段名称。 | |
| 类型 | 该字段的数据类型。 | |
| 长度 | 最大字符串长度。 | |
| 精度 | 最大小数位数。 |
使用案例
本案例使用记录注射 组件将数据注入从Kafka流注入到转换的示例。
-
创建一个名为recordinject的转换，并添加记录注射 组件。这个转换的具体流程如下：
-
配置记录注射 组件，并设置字段名称、类型、长度和精度。具体配置如下图所示：、
- 再新建一个名为kafkaConsumer的转换，其中添加Kafka Consumer 组件，总体流程设置如下：
- 配置Kafka Consumer 组件，并设置Kafka的地址、端口、主题和消费者组等信息。本实例的kafka主要配置如下图所示：
