com.tibco.messaging.kafka.avro

Class AvroSerDe

java.lang.Object

com.tibco.messaging.kafka.avro.AvroSerDe

Direct Known Subclasses:

AvroDeserializer, AvroSerializer

public abstract class AvroSerDe
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
protected boolean	isKey
protected java.lang.String	keySubjectName
protected java.lang.String	schemaRegistrationStrategy
protected java.lang.String	valueSubjectName

Constructor Summary

Constructors

Constructor and Description
AvroSerDe()

Method Summary

Modifier and Type	Method and Description
void	close()
void	configure(java.util.Map<java.lang.String,?> configs, boolean isKey)
void	configure(java.util.Map<java.lang.String,?> configs, boolean isKey, SchemaRegistryCache sharedCache)

Methods inherited from class java.lang.Object

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

Field Detail

isKey

protected boolean isKey

schemaRegistrationStrategy

protected java.lang.String schemaRegistrationStrategy

keySubjectName

protected java.lang.String keySubjectName

valueSubjectName

protected java.lang.String valueSubjectName

Constructor Detail

AvroSerDe

public AvroSerDe()

Method Detail

configure

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

configure

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

close

public void close()