All Classes and Interfaces
Class
Description
This class handles extracting records from an iterator and returning them to Kafka.
A functional interface that will abort the timer.
Performs a delay based on the number of successive
AbstractSourceTask.Backoff.delay() or AbstractSourceTask.Backoff.cleanDelay() calls without a
AbstractSourceTask.Backoff.reset().An interface to define the Backoff configuration.
A functional interface to return long values.
Calculates elapsed time and flags when expired.
Deprecated.
Defines the backoff policy for connectors.
ByteArrayTransformer chunks an entire object into a maximum size specified by the
TransformerFragment.TRANSFORMER_MAX_BUFFER_SIZE configuration option.The base configuration or all connectors.
The configuration fragment that defines the compression characteristics.
Config fragments encapsulate logical fragments of configuration that may be used across multiple Connectors or across
the source/sink of a connector pair.
A Context which captures all the details about the source which are required to successfully send a source record
onto Kafka
An
DistributionStrategy provides a mechanism to share the work of processing records from objects (or files)
into tasks, which are subsequently processed (potentially in parallel) by Kafka Connect workers.Fragment to handle all file name extraction operations.
FilePatternUtils allows the construction of a regex pattern to extract the
Context from an Object Key.A
ConfigDef.Recommender that always supports only the predefined set of values.A
RecordGrouper that groups records by topic, parition and key.A
RecordGrouper that groups records by key.This code was originally developed as part of the Apache Parquet project
LocalInputFile is an implementation needed by Parquet to read from local data files using
SeekableInputStream instances.Wraps an object mapper for reuse.
The definition of an entry in the OffsetManager.
The OffsetManager Key.
The interface for classes that associates
SinkRecords with files by some criteria.A simple templating engine that allows to bind variables to supplier functions.
A Spliterator that performs various checks on the opening/closing of the input stream.
A factory to create Transformers.
SinkCommonConfiginstead