io.druid.data.input.schemarepo

Class Avro1124SubjectAndIdConverter

java.lang.Object

io.druid.data.input.schemarepo.Avro1124SubjectAndIdConverter

All Implemented Interfaces:

SubjectAndIdConverter<String,Integer>

public class Avro1124SubjectAndIdConverter
extends Object
implements SubjectAndIdConverter<String,Integer>

This implementation using injected Kafka topic name as subject name, and an integer as schema id. Before sending avro message to Kafka broker, you need to register the schema to an schema repository, get the schema id, serialized it to 4 bytes and then insert them to the head of the payload. In the reading end, you extract 4 bytes from raw messages, deserialize and return it with the topic name, with which you can lookup the avro schema.

See Also:

SubjectAndIdConverter

Constructor Summary

Constructors

Constructor and Description
Avro1124SubjectAndIdConverter(String topic)

Method Summary

Modifier and Type	Method and Description
boolean	equals(Object o)
org.schemarepo.api.converter.Converter<Integer>	getIdConverter()
Pair<String,Integer>	getSubjectAndId(ByteBuffer payload)
org.schemarepo.api.converter.Converter<String>	getSubjectConverter()
String	getTopic()
int	hashCode()
void	putSubjectAndId(String subject, Integer id, ByteBuffer payload)

Methods inherited from class java.lang.Object

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

Constructor Detail

Avro1124SubjectAndIdConverter

public Avro1124SubjectAndIdConverter(String topic)

Method Detail

getSubjectAndId

public Pair<String,Integer> getSubjectAndId(ByteBuffer payload)

Specified by:

getSubjectAndId in interface SubjectAndIdConverter<String,Integer>

putSubjectAndId

public void putSubjectAndId(String subject,
                            Integer id,
                            ByteBuffer payload)

Specified by:

putSubjectAndId in interface SubjectAndIdConverter<String,Integer>

getSubjectConverter

public org.schemarepo.api.converter.Converter<String> getSubjectConverter()

Specified by:

getSubjectConverter in interface SubjectAndIdConverter<String,Integer>

getIdConverter

public org.schemarepo.api.converter.Converter<Integer> getIdConverter()

Specified by:

getIdConverter in interface SubjectAndIdConverter<String,Integer>

getTopic

public String getTopic()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object