All Classes and Interfaces
Class
Description
Base implementation for AMQP strategies.
A mapping for AMQP trackers to SinkRecords.
Standard AMQP message strategy.
The methods that must be implemented by both source and sink.
The context for the AMQP processes.
The builder fro the AMQP Context.
EncoderDecoder to store AMQP messages in binary format.
Converts AMQP values.
Definition of the AMQP input/output format.
The AMQP Fragment.
The Setter for the AMQP fragment.
The properties found in the message object that are not otherwise handled with maps.
The OffsetManager Entry for the AMQP messages
Exception thrown when data from AMQP can not be parsed into a Kafka friendly format.
A write strategy that expects the AMQP message to be contained in the Kafka value byte stream.
The AMQP Sink configuration.
The configuration definition for AMQP sink.
The Setter for the AMQP sink specific options.
The AMQP sink connector.
An AMQP sink task that implements a single strategy.
Automatically generated from filtered-source AmqpVersionInfo.java during
source-generate execution
The configuration for an AMQP Source connector.
The configuration file for the AMQP source.
The AMQP source connector
The AMQP NativeSourceData implementation.
Wraps ULID.Value and the Delivery for a streaming object.
The AMQP source task.
Automatically generated from filtered-source AmqpVersionInfo.java during
source-generate execution
An enumeration of write strategies
Converts collections and maps with arbitrary values into Kafka
Struct types.Abstract class to encode objects as SchemaAndValue objects and to decode SchemaAndValue object
into Objects.
A EncoderDecoder that chains multiple converters together.
Handles records that could not be sent.
An implementation of ErrantRecordReporter that simply logs the data.
Extracts the Kafka connect headers from the AMQP message.
Performs Kafka conversions.
A record that is used to track offsets from Kafka.
Definition of a write strategy.
Converts Unique type objects.