AvroReader

文档中心 › 组件索引 › AvroReader

AvroReader Controller Service

类型全限定名：cn.org.acal.lynxus.avro.AvroReader

所属 Bundle：cn.org.acal.lynxus:lynxus-record-serialization-services-nar:2.11.8

描述

解析 Avro 数据并将每个 Avro 记录作为单独的 Record 对象返回。 Avro 数据可能包含架构本身，或者架构可以通过“架构访问策略”属性提供的方法之一进行外部化和访问。

标签

avroparserecordrowreaderdelimitedcommaseparatedvalues

属性

下表中，加粗的属性为必填项；其余为可选项。表格同时标注默认值、是否支持表达式语言，以及是否为敏感属性（值会被加密）。

名称默认值可选值描述
Schema Access Strategyembedded-avro-schema
  • 使用 'Schema Name' 属性 — 要使用的 Schema 名称由 'Schema Name' 属性指定。此属性的值用于在配置的 Schema Registry 服务中查找 Schema。
  • 使用 'Schema Text' 属性 — Schema 本身的文本由 'Schema Text' 属性指定。此属性的值必须是有效的 Avro Schema。如果使用表达式语言，则 'Schema Text' 属性的值在替换表达式后必须有效。
  • Schema 引用读取器 — Schema 引用信息将通过配置的 Schema 引用读取器服务实现提供。
  • 使用嵌入的 Avro Schema — FlowFile 的内容中嵌入了 Avro Schema，将使用该 Schema。
指定如何获取用于解释数据的架构。
Schema Registry控制器服务 API：
SchemaRegistry
cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8		指定用于架构Registry的Controller Service
Schema Name${schema.name}指定要在架构Registry属性中查找的架构名称
支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Schema Version指定在 Schema Registry 中查找 Schema 的版本。如果未指定，则检索 Schema 的最新版本。
支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Schema Branch指定在 Schema Registry 属性中查找 Schema 时使用的分支名称。如果选择的 Schema Registry 不支持分支，则此值将被忽略。
支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Schema Text${avro.schema}Avro 格式的架构文本
支持表达式语言：是（使用 FlowFile 属性与环境/系统变量求值）
Schema Reference Reader控制器服务 API：
SchemaReferenceReader
cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8		服务实现负责读取 FlowFile 属性或内容以确定架构参考标识符
Cache Size1000指定应缓存多少个 Schema
Fast Reader Enabledtrue
  • true
  • false
启用后，Avro 库将使用优化的读取器实现，通过在初始化时创建详细的执行计划来提升读取性能。然而，此优化可能导致内存消耗显著增加，尤其是在使用 Schema 推断时。如果在 Avro 处理过程中出现 OutOfMemory 错误，请考虑禁用此选项。

状态管理

该组件不存储状态。

受限 (Restricted)

该组件不受限。

提供的 Service API

  • RecordReaderFactory (cn.org.acal.lynxus-lynxus-standard-services-api-nar-2.11.8)
© 2026 ACAL Organization. Licensed under Apache License 2.0.