包

org.apache.nifi | nifi-standard-nar

描述

在指定端口监听数据报，并使用配置的记录读取器读取每个数据报的内容。然后，每个记录将使用配置的记录写入器写入到流文件中。通过指定 “Sending Host”（发送主机）和 “Sending Host Port”（发送主机端口）属性，此处理器可以限制仅监听来自特定远程主机和端口的数据报，否则它将监听来自所有主机和端口的数据报。

标签

摄取、监听、记录、源、UDP

输入要求

禁止

支持敏感动态属性

否

属性

• Batch Size：写入单个流文件作为记录的最大数据报数量。只有在数据传入频率高于 “Poll Timeout”（轮询超时）时，才会达到 “Batch Size”。

• 显示名称：Batch Size
• 描述：写入单个流文件作为记录的最大数据报数量。只有在数据传入频率高于 “Poll Timeout”（轮询超时）时，才会达到 “Batch Size”。
• API名称：batch-size
• 默认值：1000
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必填：是

• Character Set：指定接收到的数据的字符集。

• 显示名称：Character Set
• 描述：指定接收到的数据的字符集。
• API名称：Character Set
• 默认值：UTF-8
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必填：是

• Local Network Interface：用于限制仅监听特定局域网的本地网络接口名称。

• 显示名称：Local Network Interface
• 描述：用于限制仅监听特定局域网的本地网络接口名称。
• API名称：Local Network Interface
• 表达式语言作用域：JVM级定义的环境变量和系统属性
• 是否敏感：否
• 是否必填：否

• Max Size of Message Queue：用于缓冲从底层通道传输到处理器的消息的内部队列的最大大小。将此值设置得较高，可以在传入消息激增期间在内存中缓冲更多消息，但会增加处理器使用的总内存。

• 显示名称：Max Size of Message Queue
• 描述：用于缓冲从底层通道传输到处理器的消息的内部队列的最大大小。将此值设置得较高，可以在传入消息激增期间在内存中缓冲更多消息，但会增加处理器使用的总内存。
• API名称：Max Size of Message Queue
• 默认值：10000
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必填：是

• Max Size of Socket Buffer：应使用的套接字缓冲区的最大大小。这是向操作系统提出的关于套接字缓冲区大小的建议。如果此值设置得过低，缓冲区可能在数据读取之前就已满，传入的数据将被丢弃。

• 显示名称：Max Size of Socket Buffer
• 描述：应使用的套接字缓冲区的最大大小。这是向操作系统提出的关于套接字缓冲区大小的建议。如果此值设置得过低，缓冲区可能在数据读取之前就已满，传入的数据将被丢弃。
• API名称：Max Size of Socket Buffer
• 默认值：1MB
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必填：是

• Poll Timeout：在轮询内部队列获取更多数据报时等待的时间量。如果在等待配置的超时时间后未找到数据报，则处理器将发出截至该点已获取的所有记录。

• 显示名称：Poll Timeout
• 描述：在轮询内部队列获取更多数据报时等待的时间量。如果在等待配置的超时时间后未找到数据报，则处理器将发出截至该点已获取的所有记录。
• API名称：poll-timeout
• 默认值：50ms
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必填：是

• Port：监听通信的端口。

• 显示名称：Port
• 描述：监听通信的端口。
• API名称：Port
• 表达式语言作用域：JVM级定义的环境变量和系统属性
• 是否敏感：否
• 是否必填：是

• Receive Buffer Size：用于接收消息的每个缓冲区的大小。根据预期传入消息的大小适当调整此值。

• 显示名称：Receive Buffer Size
• 描述：用于接收消息的每个缓冲区的大小。根据预期传入消息的大小适当调整此值。
• API名称：Receive Buffer Size
• 默认值：65507B
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必填：是

• Record Reader：用于读取传入数据报内容的记录读取器。

• 显示名称：Record Reader
• 描述：用于读取传入数据报内容的记录读取器。
• API名称：record-reader
• 服务接口：org.apache.nifi.serialization.RecordReaderFactory
• 服务实现：org.apache.nifi.avro.AvroReader、org.apache.nifi.cef.CEFReader、org.apache.nifi.csv.CSVReader、org.apache.nifi.excel.ExcelReader、org.apache.nifi.grok.GrokReader、org.apache.nifi.json.JsonPathReader、org.apache.nifi.json.JsonTreeReader、org.apache.nifi.services.protobuf.ProtobufReader、org.apache.nifi.lookup.ReaderLookup、org.apache.nifi.record.script.ScriptedReader、org.apache.nifi.syslog.Syslog5424Reader、org.apache.nifi.syslog.SyslogReader、org.apache.nifi.windowsevent.WindowsEventLogReader、org.apache.nifi.xml.XMLReader、org.apache.nifi.yaml.YamlTreeReader
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必填：是

• Record Writer：用于在写入流文件之前对数据进行序列化的记录写入器。

• 显示名称：Record Writer
• 描述：用于在写入流文件之前对数据进行序列化的记录写入器。
• API名称：record-writer
• 服务接口：org.apache.nifi.serialization.RecordSetWriterFactory
• 服务实现：org.apache.nifi.avro.AvroRecordSetWriter、org.apache.nifi.csv.CSVRecordSetWriter、org.apache.nifi.text.FreeFormTextRecordSetWriter、org.apache.nifi.json.JsonRecordSetWriter、org.apache.nifi.lookup.RecordSetWriterLookup、org.apache.nifi.record.script.ScriptedRecordSetWriter、org.apache.nifi.xml.XMLRecordSetWriter
• 表达式语言作用域：不支持
• 是否敏感：否
• 是否必填：是

• Sending Host：远程主机的IP或名称。只有来自指定的 “Sending Host Port”（发送主机端口）和此主机的数据报才会被接受。可提高性能。可以是系统属性或环境变量。

• 显示名称：Sending Host
• 描述：远程主机的IP或名称。只有来自指定的 “Sending Host Port”（发送主机端口）和此主机的数据报才会被接受。可提高性能。可以是系统属性或环境变量。
• API名称：sending-host
• 表达式语言作用域：JVM级定义的环境变量和系统属性
• 是否敏感：否
• 是否必填：否

• Sending Host Port：远程主机用于发送数据报的端口。只有来自指定的 “Sending Host”（发送主机）和此端口的数据报才会被接受。可提高性能。可以是系统属性或环境变量。

• 显示名称：Sending Host Port
• 描述：远程主机用于发送数据报的端口。只有来自指定的 “Sending Host”（发送主机）和此端口的数据报才会被接受。可提高性能。可以是系统属性或环境变量。
• API名称：sending-hostport
• 表达式语言作用域：JVM级定义的环境变量和系统属性
• 是否敏感：否
• 是否必填：否

关系

写入属性