Package io.aiven.kafka.connect.amqp

Class AmqpConverter

java.lang.Object

io.aiven.kafka.connect.amqp.AmqpConverter

All Implemented Interfaces:

org.apache.kafka.connect.storage.Converter

public class AmqpConverter
extends Object
implements org.apache.kafka.connect.storage.Converter

EncoderDecoder to store AMQP messages in binary format.

Data from the connector is expected to have a value that is an instance of an Apache QPID ProtonJ2 Message. The schema is ignored. The resulting byte[] if formatted as per the ProtonJ2 message format.

Data formatted to the connector expects the byte[] to be in QPID ProtonJ2 format. It returns a SchemaAndValue with a null schema and the value a QPID ProtonJ2 Message

Constructor Summary

Constructors

Constructor	Description
AmqpConverter()	Constructor.

Method Summary

Modifier and Type	Method	Description
void	configure(Map<String,?> configs, boolean isKey)
byte[]	fromConnectData(String topic, org.apache.kafka.connect.data.Schema schema, Object value)
org.apache.kafka.connect.data.SchemaAndValue	toConnectData(String topic, byte[] value)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.connect.storage.Converter

config, fromConnectData, toConnectData

Constructor Details

AmqpConverter

public AmqpConverter()

Constructor.

Method Details

configure

public void configure(Map<String,?> configs,
 boolean isKey)

Specified by:

configure in interface org.apache.kafka.connect.storage.Converter

fromConnectData

public byte[] fromConnectData(String topic,
 org.apache.kafka.connect.data.Schema schema,
 Object value)

Specified by:

fromConnectData in interface org.apache.kafka.connect.storage.Converter

toConnectData

public org.apache.kafka.connect.data.SchemaAndValue toConnectData(String topic,
 byte[] value)

Specified by:

toConnectData in interface org.apache.kafka.connect.storage.Converter