File Readers
The FilePulseSourceTask uses the FileInputReader.
configured in the connector’s configuration for reading object files (i.e., tasks.reader.class).
Currently, Connect FilePulse provides the following FileInputReader implementations :
Amazon S3
package: io.streamthoughts.kafka.connect.filepulse.fs.reader
AmazonS3AvroFileInputReaderAmazonS3BytesArrayInputReaderAmazonS3RowFileInputReaderAmazonS3XMLFileInputReaderAmazonS3MetadataFileInputReader
Azure Blob Storage
package: io.streamthoughts.kafka.connect.filepulse.fs.reader
AzureBlobStorageAvroFileInputReaderAzureBlobStorageBytesArrayInputReaderAzureBlobStorageRowFileInputReaderAzureBlobStorageXMLFileInputReaderAzureBlobStorageMetadataFileInputReader
Google Cloud Storage
package: io.streamthoughts.kafka.connect.filepulse.fs.reader
GcsAvroFileInputReaderGcsBytesArrayInputReaderGcsRowFileInputReaderGcsXMLFileInputReaderGcsMetadataFileInputReader
Local Filesystem
package: io.streamthoughts.kafka.connect.filepulse.fs.reader
LocalAvroFileInputReaderLocalBytesArrayInputReaderLocalRowFileInputReaderLocalXMLFileInputReaderLocalMetadataFileInputReader
RowFileInputReader (default)
The <PREFIX>RowFileInputReaders can be used to read files line by line.
This reader creates one record per row. It should be used for reading delimited text files, application log files, etc.
Configuration
| Configuration | Description | Type | Default | Importance |
|---|---|---|---|---|
file.encoding | The text file encoding to use | String | UTF_8 | High |
buffer.initial.bytes.size | The initial buffer size used to read input files. | String | 4096 | Medium |
min.read.records | The minimum number of records to read from file before returning to task. | Integer | 1 | Medium |
skip.headers | The number of rows to be skipped in the beginning of file. | Integer | 0 | Medium |
skip.footers | The number of rows to be skipped at the end of file. | Integer | 0 | Medium |
read.max.wait.ms | The maximum time to wait in milliseconds for more bytes after hitting end of file. | Long | 0 | Medium |
XxxBytesArrayInputReader
The <PREFIX>BytesArrayInputReaders create a single byte array record from a source file.
XxxAvroFileInputReader
The <PREFIX>AvroFileInputReaders can be used to read Avro files.
XxxXMLFileInputReader
The <PREFIX>XMLFileInputReaders can be used to read XML files.
Configuration
| Configuration | Since | Description | Type | Default | Importance |
|---|---|---|---|---|---|
reader.xpath.expression | The XPath expression used extract data from XML input files | String | / | High | |
reader.xpath.result.type | The expected result type for the XPath expression in [NODESET, STRING] | String | NODESET | High | |
reader.xml.force.array.on.fields | The comma-separated list of fields for which an array-type must be forced | List | - | High | |
reader.xml.parser.validating.enabled | 2.2.0 | Specifies that the parser will validate documents as they are parsed (default: false)."; | |||
reader.xml.parser.namespace.aware.enabled | 2.2.0 | Specifies that the XML parser will provide support for XML namespaces (default: false)."; | |||
reader.xml.exclude.empty.elements | 2.2.0 | Specifies that the reader should exclude element having no field (default: false)."; | |||
reader.xml.exclude.node.attributes | 2.4.0 | Specifies that the reader should exclude all node attributes (default: false)."; | |||
reader.xml.exclude.node.attributes.in.namespaces | 2.4.0 | Specifies that the reader should only exclude node attributes in the defined list of namespaces."; | |||
reader.xml.data.type.inference.enabled | 2.3.0 | Specifies that the reader should try to infer the type of data nodes (default: false)."; | |||
reader.xml.attribute.prefix | 2.4.0 | If set, the name of attributes will be prepended with the specified prefix when they are added to a record (default: ‘’)."; |
XxxMetadataFileInputReader
The FileInputMetadataReaders can be used to send a single record per file containing metadata, i.e.: name, path, hash, lastModified, size, etc.