Package io.aiven.kafka.connect.amqp.source

Class AmqpSourceData

java.lang.Object

io.aiven.commons.kafka.connector.source.NativeSourceData<String>

io.aiven.kafka.connect.amqp.source.AmqpSourceData

All Implemented Interfaces:

AutoCloseable

public final class AmqpSourceData
extends io.aiven.commons.kafka.connector.source.NativeSourceData<String>

The AMQP NativeSourceData implementation.

This implementation reads Delivery records from a protonj2 Receiver and creates AmqpSourceNativeInfo objects from those.

Since Message objects are not required to have a unique ID, this implementation uses a ULID for the native key. ULIDs are generated in the AmqpSourceNativeInfo class.

Nested Class Summary

Nested classes/interfaces inherited from class io.aiven.commons.kafka.connector.source.NativeSourceData

io.aiven.commons.kafka.connector.source.NativeSourceData.KeySerde<K>

Method Summary

Modifier and Type	Method	Description
void	close()
protected io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerEntry	createOffsetManagerEntry(io.aiven.commons.kafka.connector.source.task.Context context)
io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerEntry	createOffsetManagerEntry(Map<String,Object> data)
Iterator<AmqpSourceNativeInfo>	getNativeItemIterator(String ignore)
protected Optional<io.aiven.commons.kafka.connector.source.NativeSourceData.KeySerde<String>>	getNativeKeySerde()
io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerKey	getOffsetManagerKey(String nativeKey)
String	getSourceName()
protected Function<io.aiven.commons.kafka.connector.source.EvolvingSourceRecord,io.aiven.commons.kafka.connector.source.EvolvingSourceRecord>	initializeRecordFunction()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

initializeRecordFunction

protected Function<io.aiven.commons.kafka.connector.source.EvolvingSourceRecord,io.aiven.commons.kafka.connector.source.EvolvingSourceRecord> initializeRecordFunction()

Overrides:

initializeRecordFunction in class io.aiven.commons.kafka.connector.source.NativeSourceData<String>

getSourceName

public String getSourceName()

Specified by:

getSourceName in class io.aiven.commons.kafka.connector.source.NativeSourceData<String>

getNativeItemIterator

public Iterator<AmqpSourceNativeInfo> getNativeItemIterator(String ignore)

Specified by:

getNativeItemIterator in class io.aiven.commons.kafka.connector.source.NativeSourceData<String>

createOffsetManagerEntry

public io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerEntry createOffsetManagerEntry(Map<String,Object> data)

Specified by:

createOffsetManagerEntry in class io.aiven.commons.kafka.connector.source.NativeSourceData<String>

createOffsetManagerEntry

protected io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerEntry createOffsetManagerEntry(io.aiven.commons.kafka.connector.source.task.Context context)

Specified by:

createOffsetManagerEntry in class io.aiven.commons.kafka.connector.source.NativeSourceData<String>

getNativeKeySerde

protected Optional<io.aiven.commons.kafka.connector.source.NativeSourceData.KeySerde<String>> getNativeKeySerde()

Specified by:

getNativeKeySerde in class io.aiven.commons.kafka.connector.source.NativeSourceData<String>

getOffsetManagerKey

public io.aiven.commons.kafka.connector.source.OffsetManager.OffsetManagerKey getOffsetManagerKey(String nativeKey)

Specified by:

getOffsetManagerKey in class io.aiven.commons.kafka.connector.source.NativeSourceData<String>

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Overrides:

close in class io.aiven.commons.kafka.connector.source.NativeSourceData<String>

Throws:

Exception