com.tibco.messaging.kafka.avro

Class AvroConverter

java.lang.Object

com.tibco.messaging.kafka.avro.AvroConverter

All Implemented Interfaces:

org.apache.kafka.connect.storage.Converter

public class AvroConverter
extends java.lang.Object
implements org.apache.kafka.connect.storage.Converter

Constructor Summary

Constructors

Constructor and Description
AvroConverter()

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroConverter

public AvroConverter()

Method Detail

configure

public void configure(java.util.Map<java.lang.String,?> configs,
                      boolean isKey)

Specified by:

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

fromConnectData

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

Specified by:

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

toConnectData

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

Specified by:

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