Package io.confluent.kafka.formatter

Class SchemaMessageFormatter<T>

java.lang.Object

io.confluent.kafka.formatter.SchemaMessageFormatter<T>

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.common.MessageFormatter

public abstract class SchemaMessageFormatter<T>
extends Object
implements org.apache.kafka.common.MessageFormatter

Field Summary

Fields

Modifier and Type	Field	Description
protected SchemaMessageDeserializer<T>	deserializer

Constructor Summary

Constructors

Constructor	Description
SchemaMessageFormatter()	Constructor needed by kafka console consumer.
SchemaMessageFormatter(String url, org.apache.kafka.common.serialization.Deserializer keyDeserializer)	For testing only.

Method Summary

Modifier and Type	Method	Description
void	close()
void	configure(Map<String,?> configs)
protected abstract SchemaMessageDeserializer<T>	createDeserializer(org.apache.kafka.common.serialization.Deserializer keyDeserializer)
protected abstract SchemaProvider	getProvider()
void	init(Properties props)
protected abstract void	writeTo(String topic, Boolean isKey, org.apache.kafka.common.header.Headers headers, byte[] data, PrintStream output)
void	writeTo(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> consumerRecord, PrintStream output)

Methods inherited from class java.lang.Object

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

Field Details

deserializer

protected SchemaMessageDeserializer<T> deserializer

Constructor Details

SchemaMessageFormatter

public SchemaMessageFormatter()

Constructor needed by kafka console consumer.

SchemaMessageFormatter

public SchemaMessageFormatter(String url,
 org.apache.kafka.common.serialization.Deserializer keyDeserializer)

For testing only.

Method Details

createDeserializer

protected abstract SchemaMessageDeserializer<T> createDeserializer(org.apache.kafka.common.serialization.Deserializer keyDeserializer)

configure

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

Specified by:

configure in interface org.apache.kafka.common.Configurable

Specified by:

configure in interface org.apache.kafka.common.MessageFormatter

init

public void init(Properties props)

writeTo

public void writeTo(org.apache.kafka.clients.consumer.ConsumerRecord<byte[],byte[]> consumerRecord,
 PrintStream output)

Specified by:

writeTo in interface org.apache.kafka.common.MessageFormatter

writeTo

protected abstract void writeTo(String topic,
 Boolean isKey,
 org.apache.kafka.common.header.Headers headers,
 byte[] data,
 PrintStream output)
                         throws IOException

Throws:

IOException

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Specified by:

close in interface org.apache.kafka.common.MessageFormatter

getProvider

protected abstract SchemaProvider getProvider()