ProtobufReader

描述

从二进制格式解析协议缓冲区消息。

标签

parser、protobuf、reader、record

属性

下表列出了各项属性,其中带星号 (*) 的为必需属性。其他属性视为可选属性。该表还指出了所有默认值以及属性是否支持 NiFi 表达式语言。

显示名称

API 名称

默认值

允许值

描述

消息类型 *

消息类型

协议缓冲区消息类型的完全限定名称,包括其包名称(例如 mypackage.MyMessage)。在“Proto 目录”中配置的 .proto 文件必须包含此消息类型的定义。

Proto 目录 *

Proto 目录

包含协议缓冲区消息定义 (.proto) 文件的目录。

架构访问策略 *

schema-access-strategy

generate-from-proto-file

  • 使用“架构名称”属性

  • 使用“架构文本”属性

  • 架构参考读取器

  • 从 Proto 文件生成

指定如何获取用于解读数据的架构。

架构分支

schema-branch

指定在“架构注册表”属性中查找架构时使用的分支名称。如果所选架构注册表不支持分支,则该值将被忽略。

架构名称

schema-name

${schema.name}

指定要在架构注册表属性中查找的架构的名称。

架构参考读取器 *

schema-reference-reader

服务实现,负责读取 FlowFile 属性或内容以确定架构参考标识符

架构注册表

schema-registry

指定用于架构注册表的控制器服务

架构文本

schema-text

${avro.schema}

Avro 格式架构的文本

架构版本

schema-version

指定要在架构注册表中查找的架构版本。如果未指定,则将检索架构的最新版本。

状态管理

此组件不存储状态。

受限

此组件不受限制。

系统资源注意事项

此组件未指定系统资源注意事项。

语言: 中文