All Classes and Interfaces

Class	Description
AbstractLookbackTest	Base class for Lookback test implementations.
AbstractSourceNativeInfo<K extends Comparable<K>,N>	An abstract implementation of NativeInfo handling for Source.
AbstractSourceTask	This class handles extracting records from an iterator and returning them to Kafka.
AvroExtractor	Transforms a stream of Avro records into individual kafka messages, one per record.
AvroTestDataFixture	A testing fixture to generate/read Avro test data.
Buffer<K extends Comparable<K>>	Lookback that uses a buffer to track the last N records.
BufferTest	Test for the Buffer Lookback implementation.
ByteArrayDataFixture	The fixture to manipulate byte array data for tests.
ByteArrayExtractor	ByteArrayExtractor chunks an entire object into a maximum size specified by the extractorBuffer SourceConfigFragment.Setter.extractorBuffer(int) configuration option.
ConnectorCommonConfig	The definition of the common connector config functions.
ConnectorCommonConfig.Documentation	Configuration definitions that are added by this SourceCommonConfig.
ConnectorCommonConfigDef	The configuration definition for the common connector.
ConnectorCommonConfigFragment	The common connector fragment.
ConnectorCommonConfigFragment.Setter	Gets the setter for this fragment.
Context	A Context which captures all the details about the source object that are required to successfully send a source record onto Kafka
CsvExtractor	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.
CsvTestDataFixture	CSV Test data fixture
DistributionType	An enumeration of distribution strategies.
DistributionTypeTest	Tests the DistributionType implementations.
EvolvingSourceRecord	An evolving source record initially retrieved from the storage layer.
EvolvingSourceRecordIterator	Iterator that processes Native Source Data and creates AbstractSourceRecords.
ExampleCsvClient	A "native" client.
ExampleCsvSourceData	A simple String implementation would use a NativeClient to retrieve the NativeItems.
ExampleCsvSourceNativeInfo	This example data object has a String key and a byte buffer as its data object.
ExampleNativeClient	A "native" client.
ExampleNativeItem	A "native" object for testing.
ExampleNativeSourceData	An actual NativeSourceData implementation would use a NativeClient to retrieve the NativeItems.
ExampleOffsetManagerEntry	An implementation of OffsetManagerEntry.
ExampleSourceNativeInfo	This example data object has a String key and a byte buffer as its data object.
ExampleSourceTask	An example implementation of the Source task.
Extractor	Extracts data from the native abstract source record to Key SchemaAndValue object and a stream of SchemaAndValue objects for the values.
ExtractorInfo	The Information about the extractor.
ExtractorInfoTest	Test for ExtractorInfo functionality.
ExtractorRegistry	A registry of extractors.
ExtractorRegistry.Builder	A ExtractorRegistry builder.
ExtractorRegistryTest	Test for ExtractorRegistry functionality.
InputStreamExtractor	Extracts data from the EvolvingSourceRecord to a Key SchemaAndValue object and a stream of SchemaAndValue objects for the values.
InputStreamExtractor.StreamSpliterator	A Spliterator that performs various checks on the opening/closing of the input stream.
IOExtractorTest	Base test for extractors that consume IOSource<InputStream> objects.
IORecordExtractorTest	Base test for extractors that provide consume IOSource<InputStream> objects and produce records.
JsonExtractor	Transforms an input stream into a number of Jason records.
JsonTestDataFixture	A testing fixture to generate/read JSON data.
LastKey<K extends Comparable<K>>	A Lookback that only tracks the last key seen.
LastKeyTest	Test for LastKey Lookback implementation
Lookback<K extends Comparable<K>>	Defines the strategy for providing the next key for the client to search for.
NativeInfo<K extends Comparable<K>,N>	Information about the Native object.
NativeSourceData<K extends Comparable<K>>	A data source for native info from a source.
NativeSourceData.KeySerde<K>	A serializer / deserializer pair for a native key.
None<K extends Comparable<K>>	Lookback that does not track any keys.
NoneTest	Test for None Lookback implementation.
OffsetManager	An offset manager that handles local updates to Kafka offset manager.
OffsetManager.OffsetManagerEntry	The definition of an entry in the OffsetManager.
OffsetManager.OffsetManagerKey	The OffsetManager Key.
Parameter	A parameter is a name/value pair
ParameterDescriptor	The Description of a parameter including the name and an input validator.
ParameterDescriptor.Builder	The builder for a ParameterDescriptor.
ParquetExtractor	A Extractor that converts an input stream from a Parquet file into individual kafka messages, one per record.
SchemaAndValueFactory	A factory to create SchemaAndValue instances from arbitrary Objects.
SourceCommonConfig	The common definitions for source connectors.
SourceCommonConfig.Documentation	Configuration definitions that are added by this SourceCommonConfig.
SourceCommonConfig.SourceCommonConfigDef	The common source configuration definition.
SourceConfigFragment	Defines properties that are shared across all Source implementations.
SourceConfigFragment.Setter	The SourceConfigFragment setter.
Template	A parsed template string.
TemplateParser	A parser for a template
TemplatePart	A fragment of the template as segregated by the parser.
TemplateValidator	A validator for templates.
TemplateVariable	The template variable definition.
TemplateVariable.Builder	A builder for TemplateVariable instances.
TemplateVariableRegistry	A registry of template variables.
TemplateVariableRegistry.Builder	Builder for VariableTemplateRegistries.
TemplateVarsFactory	Creates instances of TemplateVariableRegistry for generated documentation.
TextTemplatePart	A piece of static text extracted by the parser.
VariableTemplatePart	A template part tht contains a variable definition.