Package io.aiven.commons.kafka.connector.source.extractor
package io.aiven.commons.kafka.connector.source.extractor
-
ClassDescriptionTransforms a stream of Avro records into individual kafka messages, one per record.ByteArrayExtractor chunks an entire object into a maximum size specified by the extractorBuffer
SourceConfigFragment.Setter.extractorBuffer(int)configuration option.This class provides a extractor to take a List of CSVRecord generated from apache csv-commons and transforms that data into a SchemaAndValue Object usable by Connect to add messages to Kafka.Extracts data from the native abstract source record to Key SchemaAndValue object and a stream of SchemaAndValue objects for the values.The Information about the extractor.A registry of extractors.A ExtractorRegistry builder.Extracts data from the EvolvingSourceRecord to a Key SchemaAndValue object and a stream of SchemaAndValue objects for the values.A Spliterator that performs various checks on the opening/closing of the input stream.Transforms an input stream into a number of Jason records.A Extractor that converts an input stream from a Parquet file into individual kafka messages, one per record.A factory to createSchemaAndValueinstances from arbitrary Objects.