Index

A B C D E F G H I K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form

A

ABSOLUTE_EXPIRY - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

the configured absolute time of expiration for this message

AbstractAmqpStrategy - Class in io.aiven.kafka.connect.amqp.sink.strategy

Base implementation for AMQP strategies.

AbstractAmqpStrategy(Sender, ErrantRecordHandler) - Constructor for class io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy

Constructs a strategy with the specified sender and errant record handler.

AbstractAmqpStrategy.TrackerSinkRecord - Record Class in io.aiven.kafka.connect.amqp.sink.strategy

A mapping for AMQP trackers to SinkRecords.

AmqpBodyFmt - Class in io.aiven.kafka.connect.amqp.sink.strategy

Standard AMQP message strategy.

AmqpBodyFmt(Sender, ErrantRecordHandler) - Constructor for class io.aiven.kafka.connect.amqp.sink.strategy.AmqpBodyFmt

Constructs a body format strategy.

AmqpCommonConfig - Interface in io.aiven.kafka.connect.amqp.common.config

The methods that must be implemented by both source and sink.

AmqpContext - Class in io.aiven.kafka.connect.amqp.source

The context for the AMQP processes.

AmqpContext.AmqpContextBuilder - Class in io.aiven.kafka.connect.amqp.source

The builder fro the AMQP Context.

AmqpContextBuilder(Context) - Constructor for class io.aiven.kafka.connect.amqp.source.AmqpContext.AmqpContextBuilder

Construct the builder from a context.

AmqpContextBuilder(Comparable<?>, Delivery) - Constructor for class io.aiven.kafka.connect.amqp.source.AmqpContext.AmqpContextBuilder

Construct a builder from a native key and a Delivery object.

AmqpConverter - Class in io.aiven.kafka.connect.amqp

EncoderDecoder to store AMQP messages in binary format.

AmqpConverter() - Constructor for class io.aiven.kafka.connect.amqp.AmqpConverter

Constructor.

AmqpEnDec - Class in io.aiven.kafka.connect.amqp.common.data

Converts AMQP values.

AmqpEnDec() - Constructor for class io.aiven.kafka.connect.amqp.common.data.AmqpEnDec

Constructor.

AmqpFormat - Enum Class in io.aiven.kafka.connect.amqp.common.config

Definition of the AMQP input/output format.

AmqpFragment - Class in io.aiven.kafka.connect.amqp.common.config

The AMQP Fragment.

AmqpFragment(FragmentDataAccess) - Constructor for class io.aiven.kafka.connect.amqp.common.config.AmqpFragment

Construct the ConfigFragment.

AmqpFragment.Setter - Class in io.aiven.kafka.connect.amqp.common.config

The Setter for the AMQP fragment.

AmqpHeaderProperties - Enum Class in io.aiven.kafka.connect.amqp.common.config

The properties found in the message object that are not otherwise handled with maps.

AmqpOffsetManagerEntry - Class in io.aiven.kafka.connect.amqp.source

The OffsetManager Entry for the AMQP messages

AmqpParseException - Exception Class in io.aiven.kafka.connect.amqp.common

Exception thrown when data from AMQP can not be parsed into a Kafka friendly format.

AmqpParseException(String) - Constructor for exception class io.aiven.kafka.connect.amqp.common.AmqpParseException

Constructor.

AmqpRawFmt - Class in io.aiven.kafka.connect.amqp.sink.strategy

A write strategy that expects the AMQP message to be contained in the Kafka value byte stream.

AmqpRawFmt(Sender, ErrantRecordHandler) - Constructor for class io.aiven.kafka.connect.amqp.sink.strategy.AmqpRawFmt

Constructs the strategy.

AmqpSinkConfig - Class in io.aiven.kafka.connect.amqp.sink.config

The AMQP Sink configuration.

AmqpSinkConfig(Map<String, String>) - Constructor for class io.aiven.kafka.connect.amqp.sink.config.AmqpSinkConfig

Constructor.

AmqpSinkConfigDef - Class in io.aiven.kafka.connect.amqp.sink.config

The configuration definition for AMQP sink.

AmqpSinkConfigDef() - Constructor for class io.aiven.kafka.connect.amqp.sink.config.AmqpSinkConfigDef

Constructor.

AmqpSinkConfigDef.Setter - Class in io.aiven.kafka.connect.amqp.sink.config

The Setter for the AMQP sink specific options.

AmqpSinkConnector - Class in io.aiven.kafka.connect.amqp.sink

The AMQP sink connector.

AmqpSinkConnector() - Constructor for class io.aiven.kafka.connect.amqp.sink.AmqpSinkConnector

Constructor.

AmqpSinkTask - Class in io.aiven.kafka.connect.amqp.sink

An AMQP sink task that implements a single strategy.

AmqpSinkTask() - Constructor for class io.aiven.kafka.connect.amqp.sink.AmqpSinkTask

Constructor.

AmqpSinkVersionInfo - Class in io.aiven.kafka.connect.amqp.sink

Automatically generated from filtered-source AmqpVersionInfo.java during source-generate execution

AmqpSourceConfig - Class in io.aiven.kafka.connect.amqp.source.config

The configuration for an AMQP Source connector.

AmqpSourceConfig(Map<String, String>) - Constructor for class io.aiven.kafka.connect.amqp.source.config.AmqpSourceConfig

Constructor.

AmqpSourceConfigDef - Class in io.aiven.kafka.connect.amqp.source.config

The configuration file for the AMQP source.

AmqpSourceConfigDef() - Constructor for class io.aiven.kafka.connect.amqp.source.config.AmqpSourceConfigDef

Constructor.

AmqpSourceConnector - Class in io.aiven.kafka.connect.amqp.source

The AMQP source connector

AmqpSourceConnector() - Constructor for class io.aiven.kafka.connect.amqp.source.AmqpSourceConnector

Default constructor

AmqpSourceData - Class in io.aiven.kafka.connect.amqp.source

The AMQP NativeSourceData implementation.

AmqpSourceNativeInfo - Class in io.aiven.kafka.connect.amqp.source

Wraps ULID.Value and the Delivery for a streaming object.

AmqpSourceNativeInfo(Delivery) - Constructor for class io.aiven.kafka.connect.amqp.source.AmqpSourceNativeInfo

Construct native info for a Delivery from AMQP.

AmqpSourceTask - Class in io.aiven.kafka.connect.amqp.source

The AMQP source task.

AmqpSourceTask() - Constructor for class io.aiven.kafka.connect.amqp.source.AmqpSourceTask

Default constructor.

AmqpSourceVersionInfo - Class in io.aiven.kafka.connect.amqp.source

Automatically generated from filtered-source AmqpVersionInfo.java during source-generate execution

AmqpStrategy - Enum Class in io.aiven.kafka.connect.amqp.sink.config

An enumeration of write strategies

andThen(EncoderDecoder) - Method in class io.aiven.kafka.connect.amqp.common.data.EncoderDecoder

Creates a chained converter where the nextConverter is called if this converter can not encode/decode a value.

ARTIFACT - Static variable in class io.aiven.kafka.connect.amqp.sink.AmqpSinkVersionInfo

the Maven artifact ID for this module

ARTIFACT - Static variable in class io.aiven.kafka.connect.amqp.source.AmqpSourceVersionInfo

the Maven artifact ID for this module

B

BODY - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpFormat

The body of the AMQP message is extracted and placed into the Kafka value, the Kafka value schema is set appropriately for the value, the Key is the key specified by the AMQP message or an ULID string if none was provided.

BODY - Enum constant in enum class io.aiven.kafka.connect.amqp.sink.config.AmqpStrategy

the Kafka message value contains the AMQP message body.

build() - Method in class io.aiven.kafka.connect.amqp.source.AmqpContext.AmqpContextBuilder

builder() - Method in class io.aiven.kafka.connect.amqp.source.AmqpContext

C

ChainedEnDec(EncoderDecoder...) - Constructor for class io.aiven.kafka.connect.amqp.common.data.EncoderDecoder.ChainedEnDec

Constructs a chain of converters.

close() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceData

closeResources() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceTask

CollectionEnDec - Class in io.aiven.kafka.connect.amqp.common.data

Converts collections and maps with arbitrary values into Kafka Struct types.

CollectionEnDec() - Constructor for class io.aiven.kafka.connect.amqp.common.data.CollectionEnDec

Constructor.

commitRecord(SourceRecord, RecordMetadata) - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceTask

compareTo(KafkaRecordKey) - Method in record class io.aiven.kafka.connect.amqp.common.KafkaRecordKey

config() - Method in class io.aiven.kafka.connect.amqp.sink.AmqpSinkConnector

config() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceConnector

configure(Map<String, ?>, boolean) - Method in class io.aiven.kafka.connect.amqp.AmqpConverter

configure(Map<String, String>, OffsetManager) - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceTask

CONTENT_ENCODING - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

the assigned content encoding value for the message body section or null if not set

CONTENT_TYPE - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

the assigned content type value for the message body section or null if not set.

CORRELATION_ID - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

the currently assigned correlation ID or null if none set.

createOffsetManagerEntry(Context) - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceData

createOffsetManagerEntry(Map<String, Object>) - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceData

CREATION_TIME - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

the absolute time of creation for this message

D

decode(SchemaAndValue) - Method in class io.aiven.kafka.connect.amqp.common.data.AmqpEnDec

decode(SchemaAndValue) - Method in class io.aiven.kafka.connect.amqp.common.data.CollectionEnDec

decode(SchemaAndValue) - Method in class io.aiven.kafka.connect.amqp.common.data.EncoderDecoder.ChainedEnDec

decode(SchemaAndValue) - Method in class io.aiven.kafka.connect.amqp.common.data.EncoderDecoder

Decodes a SchemaAndValue into an object.

decode(SchemaAndValue) - Method in class io.aiven.kafka.connect.amqp.common.data.KafkaEnDec

decode(SchemaAndValue) - Method in class io.aiven.kafka.connect.amqp.common.data.UniqueTypeEnDec

delivery(Delivery) - Method in class io.aiven.kafka.connect.amqp.source.AmqpContext.AmqpContextBuilder

Set the delivery in the context.

DELIVERY_COUNT - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

the number of failed delivery attempts that this message has been part of

DELIVERY_KEY - Static variable in class io.aiven.kafka.connect.amqp.source.AmqpContext

The key for the delivery property.

DURABLE - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

For an message being sent this method returns the current state of the durable flag on the message.

E

encode(Object) - Method in class io.aiven.kafka.connect.amqp.common.data.AmqpEnDec

encode(Object) - Method in class io.aiven.kafka.connect.amqp.common.data.CollectionEnDec

encode(Object) - Method in class io.aiven.kafka.connect.amqp.common.data.EncoderDecoder.ChainedEnDec

encode(Object) - Method in class io.aiven.kafka.connect.amqp.common.data.EncoderDecoder

Encodes the value as a SchemaAndValue.

encode(Object) - Method in class io.aiven.kafka.connect.amqp.common.data.KafkaEnDec

encode(Object) - Method in class io.aiven.kafka.connect.amqp.common.data.UniqueTypeEnDec

encodeCollection(SchemaBuilder, Collection<?>) - Method in class io.aiven.kafka.connect.amqp.common.data.CollectionEnDec

Create a struct that contains the items from the collection.

encoderDecoder - Variable in class io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy

The Encoder/Decoder to use

EncoderDecoder - Class in io.aiven.kafka.connect.amqp.common.data

Abstract class to encode objects as SchemaAndValue objects and to decode SchemaAndValue object into Objects.

EncoderDecoder() - Constructor for class io.aiven.kafka.connect.amqp.common.data.EncoderDecoder

Default constructor.

EncoderDecoder.ChainedEnDec - Class in io.aiven.kafka.connect.amqp.common.data

A EncoderDecoder that chains multiple converters together.

equals(Object) - Method in record class io.aiven.kafka.connect.amqp.common.KafkaRecordKey

Indicates whether some other object is "equal to" this one.

equals(Object) - Method in record class io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy.TrackerSinkRecord

Indicates whether some other object is "equal to" this one.

errantRecordHandler - Variable in class io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy

The handler for failed messages

ErrantRecordHandler - Class in io.aiven.kafka.connect.amqp.sink.errant

Handles records that could not be sent.

ErrantRecordHandler(ErrantRecordReporter) - Constructor for class io.aiven.kafka.connect.amqp.sink.errant.ErrantRecordHandler

Constructor.

ErrantRecordHandler.LoggingReporter - Class in io.aiven.kafka.connect.amqp.sink.errant

An implementation of ErrantRecordReporter that simply logs the data.

estimateInputStreamLength() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceNativeInfo

F

FIRST_ACQUIRER - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

if this message has been acquired by another link previously

flush(Map<TopicPartition, OffsetAndMetadata>) - Method in class io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy

flush(Map<TopicPartition, OffsetAndMetadata>) - Method in interface io.aiven.kafka.connect.amqp.sink.strategy.Strategy

Flushes the data to the storage.

FORMAT - Static variable in class io.aiven.kafka.connect.amqp.common.config.AmqpFragment

The key for the AMQP Message IO format.

fragmentPostProcess(CommonConfig.ChangeTrackingMap) - Method in class io.aiven.kafka.connect.amqp.sink.config.AmqpSinkConfig

Called directly after user configs got parsed (and thus default values got set).

fromConnectData(String, Schema, Object) - Method in class io.aiven.kafka.connect.amqp.AmqpConverter

fromProperties(Map<String, Object>) - Method in class io.aiven.kafka.connect.amqp.source.AmqpOffsetManagerEntry

G

getClient() - Method in interface io.aiven.kafka.connect.amqp.common.config.AmqpCommonConfig

Creates a AMQP client.

getClient() - Method in class io.aiven.kafka.connect.amqp.common.config.AmqpFragment

getClient() - Method in class io.aiven.kafka.connect.amqp.sink.config.AmqpSinkConfig

getClient() - Method in class io.aiven.kafka.connect.amqp.source.config.AmqpSourceConfig

getCommonConverter() - Static method in interface io.aiven.kafka.connect.amqp.common.config.AmqpCommonConfig

Creates the common converter with AMQP, UniqueType, Kafka, and Collection converters.

getConnection(Client) - Method in interface io.aiven.kafka.connect.amqp.common.config.AmqpCommonConfig

Creates a new Connection to an AMQP client.

getConnection(Client) - Method in class io.aiven.kafka.connect.amqp.common.config.AmqpFragment

getConnection(Client) - Method in class io.aiven.kafka.connect.amqp.sink.config.AmqpSinkConfig

getConnection(Client) - Method in class io.aiven.kafka.connect.amqp.source.config.AmqpSourceConfig

getContext() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceNativeInfo

getDelivery() - Method in class io.aiven.kafka.connect.amqp.source.AmqpContext

Gets the Delivery

getDescription() - Method in enum class io.aiven.kafka.connect.amqp.common.config.AmqpFormat

Gets the description of the use of this format.

getInputStream() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceNativeInfo

getIterator(SourceCommonConfig) - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceTask

getManagerKey() - Method in class io.aiven.kafka.connect.amqp.source.AmqpOffsetManagerEntry

getMessage() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceNativeInfo

Gets the AMQP message.

getMessageFormat() - Method in interface io.aiven.kafka.connect.amqp.common.config.AmqpCommonConfig

Gets the expected format for the AMQP message.

getMessageFormat() - Method in class io.aiven.kafka.connect.amqp.common.config.AmqpFragment

getMessageFormat() - Method in class io.aiven.kafka.connect.amqp.sink.config.AmqpSinkConfig

getMessageFormat() - Method in class io.aiven.kafka.connect.amqp.source.config.AmqpSourceConfig

getNativeItemIterator(String) - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceData

getNativeKeySerde() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceData

getOffsetManagerKey(String) - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceData

getProperties() - Method in class io.aiven.kafka.connect.amqp.source.AmqpOffsetManagerEntry

getProperty(String) - Method in class io.aiven.kafka.connect.amqp.source.AmqpOffsetManagerEntry

getReceiver() - Method in interface io.aiven.kafka.connect.amqp.common.config.AmqpCommonConfig

Creates a new AMQP Receiver by creating and using a Client and Connection.

getReceiver(Connection) - Method in interface io.aiven.kafka.connect.amqp.common.config.AmqpCommonConfig

Creates a new AMQP Receiver.

getReceiver(Connection) - Method in class io.aiven.kafka.connect.amqp.common.config.AmqpFragment

getReceiver(Connection) - Method in class io.aiven.kafka.connect.amqp.sink.config.AmqpSinkConfig

getReceiver(Connection) - Method in class io.aiven.kafka.connect.amqp.source.config.AmqpSourceConfig

getRecordCount() - Method in class io.aiven.kafka.connect.amqp.source.AmqpOffsetManagerEntry

getSchema() - Method in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

Gets the schema for this data item.

getSchemaName() - Method in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

Gets the schema name for this data item.

getSender() - Method in interface io.aiven.kafka.connect.amqp.common.config.AmqpCommonConfig

Creates a new AMQP Sender by creating and using a Client and Connection.

getSender(Connection) - Method in interface io.aiven.kafka.connect.amqp.common.config.AmqpCommonConfig

Creates a new AMQP Sender.

getSender(Connection) - Method in class io.aiven.kafka.connect.amqp.common.config.AmqpFragment

getSender(Connection) - Method in class io.aiven.kafka.connect.amqp.sink.config.AmqpSinkConfig

getSender(Connection) - Method in class io.aiven.kafka.connect.amqp.source.config.AmqpSourceConfig

getSourceName() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceData

getWriteStrategy() - Method in class io.aiven.kafka.connect.amqp.sink.config.AmqpSinkConfig

Gets the write strategy for this sink.

GROUP_ID - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

the assigned group ID for this message or null if not set.

GROUP_SEQUENCE - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

the assigned group sequence for this message.

H

hashCode() - Method in record class io.aiven.kafka.connect.amqp.common.KafkaRecordKey

Returns a hash code value for this object.

hashCode() - Method in record class io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy.TrackerSinkRecord

Returns a hash code value for this object.

HeaderExtractor - Class in io.aiven.kafka.connect.amqp.common.data

Extracts the Kafka connect headers from the AMQP message.

HeaderExtractor(EncoderDecoder) - Constructor for class io.aiven.kafka.connect.amqp.common.data.HeaderExtractor

Create the header extractor with the specified data converter.

I

incrementRecordCount() - Method in class io.aiven.kafka.connect.amqp.source.AmqpOffsetManagerEntry

initialize(SinkTaskContext) - Method in class io.aiven.kafka.connect.amqp.sink.AmqpSinkTask

initializeRecordFunction() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceData

io.aiven.kafka.connect.amqp - package io.aiven.kafka.connect.amqp

io.aiven.kafka.connect.amqp.common - package io.aiven.kafka.connect.amqp.common

io.aiven.kafka.connect.amqp.common.config - package io.aiven.kafka.connect.amqp.common.config

io.aiven.kafka.connect.amqp.common.data - package io.aiven.kafka.connect.amqp.common.data

io.aiven.kafka.connect.amqp.sink - package io.aiven.kafka.connect.amqp.sink

io.aiven.kafka.connect.amqp.sink.config - package io.aiven.kafka.connect.amqp.sink.config

io.aiven.kafka.connect.amqp.sink.errant - package io.aiven.kafka.connect.amqp.sink.errant

io.aiven.kafka.connect.amqp.sink.strategy - package io.aiven.kafka.connect.amqp.sink.strategy

io.aiven.kafka.connect.amqp.source - package io.aiven.kafka.connect.amqp.source

io.aiven.kafka.connect.amqp.source.config - package io.aiven.kafka.connect.amqp.source.config

isStream() - Method in class io.aiven.kafka.connect.amqp.source.config.AmqpSourceConfig

Determins if we are processing a stream.

K

KafkaEnDec - Class in io.aiven.kafka.connect.amqp.common.data

Performs Kafka conversions.

KafkaEnDec() - Constructor for class io.aiven.kafka.connect.amqp.common.data.KafkaEnDec

Constructs an encoder that does convert null values.

KafkaRecordKey - Record Class in io.aiven.kafka.connect.amqp.common

A record that is used to track offsets from Kafka.

KafkaRecordKey(String, int, long) - Constructor for record class io.aiven.kafka.connect.amqp.common.KafkaRecordKey

Creates an instance of a KafkaRecordKey record class.

KafkaRecordKey(RecordMetadata) - Constructor for record class io.aiven.kafka.connect.amqp.common.KafkaRecordKey

Creates an instance from a RecordMetadata instance.

KafkaRecordKey(TopicPartition, long) - Constructor for record class io.aiven.kafka.connect.amqp.common.KafkaRecordKey

Creates an instance from a TopicPartition object and an offset.

KafkaRecordKey(SinkRecord) - Constructor for record class io.aiven.kafka.connect.amqp.common.KafkaRecordKey

Creates an instance from a SinkRecord.

L

lastEvolution(EvolvingSourceRecord) - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceTask

LoggingReporter() - Constructor for class io.aiven.kafka.connect.amqp.sink.errant.ErrantRecordHandler.LoggingReporter

Constructor.

M

MESSAGE_ID - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

the currently set Message Id or null if none set.

multiValidate(Map<String, ConfigValue>) - Method in class io.aiven.kafka.connect.amqp.sink.config.AmqpSinkConfigDef

Validates the AMQP configuration is correct and meets requirements

multiValidate(Map<String, ConfigValue>) - Method in class io.aiven.kafka.connect.amqp.source.config.AmqpSourceConfigDef

Validates the AMQP configuration is correct and meets requirements

N

NAME - Static variable in class io.aiven.kafka.connect.amqp.sink.AmqpSinkVersionInfo

The name of this project

NAME - Static variable in class io.aiven.kafka.connect.amqp.source.AmqpSourceVersionInfo

The name of this project

NOT_AMQP - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpFormat

(Only valid for sink) The Kafka message did not an originate as an AMQP message.

O

offset() - Method in record class io.aiven.kafka.connect.amqp.common.KafkaRecordKey

Returns the value of the offset record component.

ORGANIZATION - Static variable in class io.aiven.kafka.connect.amqp.sink.AmqpSinkVersionInfo

The Mave norganization name for this module

ORGANIZATION - Static variable in class io.aiven.kafka.connect.amqp.source.AmqpSourceVersionInfo

The Mave norganization name for this module

P

partition() - Method in record class io.aiven.kafka.connect.amqp.common.KafkaRecordKey

Returns the value of the partition record component.

preCommit(Map<TopicPartition, OffsetAndMetadata>) - Method in class io.aiven.kafka.connect.amqp.sink.AmqpSinkTask

preCommit(Map<TopicPartition, OffsetAndMetadata>) - Method in class io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy

preCommit(Map<TopicPartition, OffsetAndMetadata>) - Method in interface io.aiven.kafka.connect.amqp.sink.strategy.Strategy

Adjust the currentOffsets to commit.

processHeaders(Headers, Message<?>) - Method in class io.aiven.kafka.connect.amqp.common.data.HeaderExtractor

processes the message and writes all non-body AMQP values into Kafka connect headers. the AmqpHeaderProperties enumeration specifies the AMQP message methods that will be extracted and placed into the specified headers.

put(Collection<SinkRecord>) - Method in class io.aiven.kafka.connect.amqp.sink.AmqpSinkTask

R

RAW - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpFormat

AMQP message is encoded into its native byte buffer format and passed to Kafka as a byte[], the Key is the key specified by the AMQP message or an ULID string if none was provided.

RAW - Enum constant in enum class io.aiven.kafka.connect.amqp.sink.config.AmqpStrategy

The Kafka message value contains the entire AMQP message

REPLY_TO - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

the configured address of the node where replies to this message should be sent, or null if not set.

REPLY_TO_GROUP_ID - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

the client-specific id used so that client can send replies to this message to a specific group.

report(SinkRecord, Throwable) - Method in class io.aiven.kafka.connect.amqp.sink.errant.ErrantRecordHandler.LoggingReporter

reportErrantRecord(SinkRecord, Exception) - Method in class io.aiven.kafka.connect.amqp.sink.errant.ErrantRecordHandler

Reports an errant record.

reportErrantRecord(SinkRecord, String) - Method in class io.aiven.kafka.connect.amqp.sink.errant.ErrantRecordHandler

Reports an errant record.

reportErrantRecords(Map<SinkRecord, Throwable>) - Method in class io.aiven.kafka.connect.amqp.sink.errant.ErrantRecordHandler

Reports a number of errant records.

reportErrantRecords(Set<SinkRecord>, Exception) - Method in class io.aiven.kafka.connect.amqp.sink.errant.ErrantRecordHandler

Reports a number of errant records.

S

self() - Method in class io.aiven.kafka.connect.amqp.common.data.EncoderDecoder

A reference to this converter.

sender - Variable in class io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy

The sender to send AMQP messages

setAddress(String) - Method in class io.aiven.kafka.connect.amqp.common.config.AmqpFragment.Setter

Sets the address for the AMQP receiver.

setHost(String) - Method in class io.aiven.kafka.connect.amqp.common.config.AmqpFragment.Setter

Sets the host value.

setMessageFormat(AmqpFormat) - Method in class io.aiven.kafka.connect.amqp.common.config.AmqpFragment.Setter

Sets the format for AMQP Message IO.

setPassword(String) - Method in class io.aiven.kafka.connect.amqp.common.config.AmqpFragment.Setter

Sets the user password to connect to the AMQP server.

setPort(int) - Method in class io.aiven.kafka.connect.amqp.common.config.AmqpFragment.Setter

Sets the port for the AMQP connection.

setProperty(String, Object) - Method in class io.aiven.kafka.connect.amqp.source.AmqpOffsetManagerEntry

setSelf(EncoderDecoder) - Method in class io.aiven.kafka.connect.amqp.common.data.EncoderDecoder.ChainedEnDec

setSelf(EncoderDecoder) - Method in class io.aiven.kafka.connect.amqp.common.data.EncoderDecoder

A method to set the EncoderDecoder against which recursive calls should be made.

setter(Map<String, String>) - Static method in class io.aiven.kafka.connect.amqp.common.config.AmqpFragment

Creates the setter for this fragment.

Setter(Map<String, String>) - Constructor for class io.aiven.kafka.connect.amqp.common.config.AmqpFragment.Setter

Constructor.

Setter(Map<String, String>) - Constructor for class io.aiven.kafka.connect.amqp.sink.config.AmqpSinkConfigDef.Setter

Constructor.

setUser(String) - Method in class io.aiven.kafka.connect.amqp.common.config.AmqpFragment.Setter

Sets the user name to connect to the AMQP server.

sinkRecord() - Method in record class io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy.TrackerSinkRecord

Returns the value of the sinkRecord record component.

start(Map<String, String>) - Method in class io.aiven.kafka.connect.amqp.sink.AmqpSinkConnector

start(Map<String, String>) - Method in class io.aiven.kafka.connect.amqp.sink.AmqpSinkTask

start(Map<String, String>) - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceConnector

stop() - Method in class io.aiven.kafka.connect.amqp.sink.AmqpSinkConnector

stop() - Method in class io.aiven.kafka.connect.amqp.sink.AmqpSinkTask

stop() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceConnector

strategy(AmqpStrategy) - Method in class io.aiven.kafka.connect.amqp.sink.config.AmqpSinkConfigDef.Setter

Sets the write strategy.

Strategy - Interface in io.aiven.kafka.connect.amqp.sink.strategy

Definition of a write strategy.

SUBJECT - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

the currently set subject metadata for this message or null if none set.

T

taskClass() - Method in class io.aiven.kafka.connect.amqp.sink.AmqpSinkConnector

taskClass() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceConnector

taskConfigs(int) - Method in class io.aiven.kafka.connect.amqp.sink.AmqpSinkConnector

taskConfigs(int) - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceConnector

TO - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

the currently set 'To' address which indicates the intended destination of the message.

toConnectData(String, byte[]) - Method in class io.aiven.kafka.connect.amqp.AmqpConverter

topic() - Method in record class io.aiven.kafka.connect.amqp.common.KafkaRecordKey

Returns the value of the topic record component.

toString() - Method in class io.aiven.kafka.connect.amqp.common.data.EncoderDecoder.ChainedEnDec

toString() - Method in class io.aiven.kafka.connect.amqp.common.data.EncoderDecoder

toString() - Method in record class io.aiven.kafka.connect.amqp.common.KafkaRecordKey

Returns a string representation of this record class.

toString() - Method in record class io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy.TrackerSinkRecord

Returns a string representation of this record class.

trackerFuture() - Method in record class io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy.TrackerSinkRecord

Returns the value of the trackerFuture record component.

TrackerSinkRecord(Future<Tracker>, SinkRecord) - Constructor for record class io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy.TrackerSinkRecord

Creates an instance of a TrackerSinkRecord record class.

U

UniqueTypeEnDec - Class in io.aiven.kafka.connect.amqp.common.data

Converts Unique type objects.

UniqueTypeEnDec() - Constructor for class io.aiven.kafka.connect.amqp.common.data.UniqueTypeEnDec

Constructor that does not use pattern matching.

UniqueTypeEnDec(boolean) - Constructor for class io.aiven.kafka.connect.amqp.common.data.UniqueTypeEnDec

Constructor.

update(ConfigDef) - Static method in class io.aiven.kafka.connect.amqp.common.config.AmqpFragment

Adds the configuration options for compression to the configuration definition.

USER_ID - Enum constant in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

the currently set User ID or null if none set.

V

valueOf(String) - Static method in enum class io.aiven.kafka.connect.amqp.common.config.AmqpFormat

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

Returns the enum constant of this class with the specified name.

valueOf(String) - Static method in enum class io.aiven.kafka.connect.amqp.sink.config.AmqpStrategy

Returns the enum constant of this class with the specified name.

values() - Static method in enum class io.aiven.kafka.connect.amqp.common.config.AmqpFormat

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.aiven.kafka.connect.amqp.common.config.AmqpHeaderProperties

Returns an array containing the constants of this enum class, in the order they are declared.

values() - Static method in enum class io.aiven.kafka.connect.amqp.sink.config.AmqpStrategy

Returns an array containing the constants of this enum class, in the order they are declared.

version() - Method in class io.aiven.kafka.connect.amqp.sink.AmqpSinkConnector

version() - Method in class io.aiven.kafka.connect.amqp.sink.AmqpSinkTask

version() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceConnector

version() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceTask

VERSION - Static variable in class io.aiven.kafka.connect.amqp.sink.AmqpSinkVersionInfo

The version of this instance

VERSION - Static variable in class io.aiven.kafka.connect.amqp.source.AmqpSourceVersionInfo

The version of this instance

W

write(Collection<SinkRecord>) - Method in interface io.aiven.kafka.connect.amqp.sink.strategy.Strategy

Writes multiple SinkRecords.

write(SinkRecord) - Method in class io.aiven.kafka.connect.amqp.sink.strategy.AbstractAmqpStrategy

write(SinkRecord) - Method in interface io.aiven.kafka.connect.amqp.sink.strategy.Strategy

Writes a single sinkRecord.

A B C D E F G H I K L M N O P R S T U V W
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form