Index
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
- AmqpBinarySerializer - Class in io.aiven.kafka.connect.amqp.source.extractor
-
A AmqpBinarySerializer wrapper that presents an immutable view of a payload.
- AmqpBinarySerializer() - Constructor for class io.aiven.kafka.connect.amqp.source.extractor.AmqpBinarySerializer
-
Default constructor.
- AmqpBinarySerializer(Class<Binary>) - Constructor for class io.aiven.kafka.connect.amqp.source.extractor.AmqpBinarySerializer
-
Constructor for a specific section type.
- AmqpCommonConfig - Interface in io.aiven.kafka.connect.amqp.common.config
-
The methods that must be implemented by both source and sink.
- AmqpDecimal128Serializer - Class in io.aiven.kafka.connect.amqp.source.extractor
-
A AmqpBinarySerializer wrapper that presents an immutable view of a payload.
- AmqpDecimal128Serializer() - Constructor for class io.aiven.kafka.connect.amqp.source.extractor.AmqpDecimal128Serializer
-
Default constructor.
- AmqpDecimal32Serializer - Class in io.aiven.kafka.connect.amqp.source.extractor
-
A AmqpBinarySerializer wrapper that presents an immutable view of a payload.
- AmqpDecimal32Serializer() - Constructor for class io.aiven.kafka.connect.amqp.source.extractor.AmqpDecimal32Serializer
-
Default constructor.
- AmqpDecimal64Serializer - Class in io.aiven.kafka.connect.amqp.source.extractor
-
A AmqpBinarySerializer wrapper that presents an immutable view of a payload.
- AmqpDecimal64Serializer() - Constructor for class io.aiven.kafka.connect.amqp.source.extractor.AmqpDecimal64Serializer
-
Default constructor.
- AmqpExtractor - Class in io.aiven.kafka.connect.amqp.source.extractor
-
Extracts data from the AMQP Message.
- AmqpExtractor(SourceCommonConfig) - Constructor for class io.aiven.kafka.connect.amqp.source.extractor.AmqpExtractor
-
Creates AmqpExtractor
- 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
- AmqpSectionSerializer - Class in io.aiven.kafka.connect.amqp.source.extractor
-
Serializes sections of an AMQP message into a JSON format.
- AmqpSectionSerializer() - Constructor for class io.aiven.kafka.connect.amqp.source.extractor.AmqpSectionSerializer
-
Default constructor.
- AmqpSectionSerializer(Class<Section>) - Constructor for class io.aiven.kafka.connect.amqp.source.extractor.AmqpSectionSerializer
-
Constructor for a specific section type.
- 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.
- AmqpSourceData.ULIDSerde - Class in io.aiven.kafka.connect.amqp.source
-
The AMQP native source data implementation of NativeSourceData.KeySerde.
- 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
- AmqpSymbolSerializer - Class in io.aiven.kafka.connect.amqp.source.extractor
-
A AmqpBinarySerializer wrapper that presents an immutable view of a payload.
- AmqpSymbolSerializer() - Constructor for class io.aiven.kafka.connect.amqp.source.extractor.AmqpSymbolSerializer
-
Default constructor.
- ARTIFACT - Static variable in class io.aiven.kafka.connect.amqp.source.AmqpSourceVersionInfo
-
the Maven artifact ID for this module
C
- close() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceData
- closeResources() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceTask
- config() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceConnector
- 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
- 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
- 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
- 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
- fromProperties(Map<String, Object>) - Method in class io.aiven.kafka.connect.amqp.source.AmqpOffsetManagerEntry
- fromString(String) - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceData.ULIDSerde
G
- generateKeyData(EvolvingSourceRecord) - Method in class io.aiven.kafka.connect.amqp.source.extractor.AmqpExtractor
- generateRecords(EvolvingSourceRecord) - Method in class io.aiven.kafka.connect.amqp.source.extractor.AmqpExtractor
- 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.source.config.AmqpSourceConfig
- 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.source.config.AmqpSourceConfig
- getContext() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceNativeInfo
- 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.
- getNativeItemIterator(ULID.Value) - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceData
- getNativeKeySerde() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceData
- getOffsetManagerKey(ULID.Value) - 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.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.
- getSourceName() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceData
- 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.
I
- incrementRecordCount() - Method in class io.aiven.kafka.connect.amqp.source.AmqpOffsetManagerEntry
- info() - Static method in class io.aiven.kafka.connect.amqp.source.extractor.AmqpExtractor
-
Creates an ExtractorInfo for this extractor.
- io.aiven.kafka.connect.amqp.common.config - package io.aiven.kafka.connect.amqp.common.config
- 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
- io.aiven.kafka.connect.amqp.source.extractor - package io.aiven.kafka.connect.amqp.source.extractor
- isStream() - Method in class io.aiven.kafka.connect.amqp.source.config.AmqpSourceConfig
-
Determins if we are processing a stream.
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.
- MessageSerializer - Class in io.aiven.kafka.connect.amqp.source.extractor
-
Serializes an AMQP Message into a JSON format.
- MessageSerializer() - Constructor for class io.aiven.kafka.connect.amqp.source.extractor.MessageSerializer
-
Default constructor.
- MessageSerializer(Class<Message>) - Constructor for class io.aiven.kafka.connect.amqp.source.extractor.MessageSerializer
-
Constructor for an arbitrary Message.
- 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.source.AmqpSourceVersionInfo
-
The name of this project
O
- ORGANIZATION - Static variable in class io.aiven.kafka.connect.amqp.source.AmqpSourceVersionInfo
-
The Mave norganization name for this module
R
- registerSerializers(ObjectMapper) - Static method in class io.aiven.kafka.connect.amqp.source.extractor.AmqpExtractor
-
Registeres the standard JSON serializers used by the extractor.
- 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.
S
- serialize(Message, JsonGenerator, SerializerProvider) - Method in class io.aiven.kafka.connect.amqp.source.extractor.MessageSerializer
- serialize(Binary, JsonGenerator, SerializerProvider) - Method in class io.aiven.kafka.connect.amqp.source.extractor.AmqpBinarySerializer
- serialize(Decimal128, JsonGenerator, SerializerProvider) - Method in class io.aiven.kafka.connect.amqp.source.extractor.AmqpDecimal128Serializer
- serialize(Decimal32, JsonGenerator, SerializerProvider) - Method in class io.aiven.kafka.connect.amqp.source.extractor.AmqpDecimal32Serializer
- serialize(Decimal64, JsonGenerator, SerializerProvider) - Method in class io.aiven.kafka.connect.amqp.source.extractor.AmqpDecimal64Serializer
- serialize(Section, JsonGenerator, SerializerProvider) - Method in class io.aiven.kafka.connect.amqp.source.extractor.AmqpSectionSerializer
- serialize(Symbol, JsonGenerator, SerializerProvider) - Method in class io.aiven.kafka.connect.amqp.source.extractor.AmqpSymbolSerializer
- 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.
- 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
- 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.
- setUser(String) - Method in class io.aiven.kafka.connect.amqp.common.config.AmqpFragment.Setter
-
Sets the user name to connect to the AMQP server.
- start(Map<String, String>) - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceConnector
- stop() - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceConnector
- 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.source.AmqpSourceConnector
- 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.
- toString(ULID.Value) - Method in class io.aiven.kafka.connect.amqp.source.AmqpSourceData.ULIDSerde
U
- ULIDSerde() - Constructor for class io.aiven.kafka.connect.amqp.source.AmqpSourceData.ULIDSerde
-
Default 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.AmqpHeaderProperties
-
Returns the enum constant of this class with the specified name.
- 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.
- 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.source.AmqpSourceVersionInfo
-
The version of this instance
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form