io.confluent.kafka.formatter

Class SchemaMessageReader<T>

java.lang.Object

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

All Implemented Interfaces:

kafka.common.MessageReader

public abstract class SchemaMessageReader<T>
extends Object
implements kafka.common.MessageReader

Field Summary

Fields

Modifier and Type	Field and Description
static String	KEY_SCHEMA
protected ParsedSchema	keySchema
static String	VALUE_SCHEMA
protected ParsedSchema	valueSchema

Constructor Summary

Constructors

Constructor and Description
SchemaMessageReader() Constructor needed by kafka console producer.
SchemaMessageReader(String url, ParsedSchema keySchema, ParsedSchema valueSchema, String topic, boolean parseKey, BufferedReader reader, boolean normalizeSchema, boolean autoRegister, boolean useLatest) For testing only.

Method Summary

Modifier and Type	Method and Description
void	close()
protected abstract SchemaMessageSerializer<T>	createSerializer(org.apache.kafka.common.serialization.Serializer keySerializer)
protected abstract SchemaProvider	getProvider()
void	init(InputStream inputStream, Properties props)
protected ParsedSchema	parseSchema(SchemaRegistryClient schemaRegistry, String schema, List<SchemaReference> references)
protected abstract T	readFrom(String jsonString, ParsedSchema schema)
org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]>	readMessage()

Methods inherited from class java.lang.Object

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

Methods inherited from interface kafka.common.MessageReader

$init$

Field Detail

VALUE_SCHEMA

public static final String VALUE_SCHEMA

See Also:

Constant Field Values

KEY_SCHEMA

public static final String KEY_SCHEMA

See Also:

Constant Field Values

keySchema

protected ParsedSchema keySchema

valueSchema

protected ParsedSchema valueSchema

Constructor Detail

SchemaMessageReader

public SchemaMessageReader()

Constructor needed by kafka console producer.

SchemaMessageReader

public SchemaMessageReader(String url,
                           ParsedSchema keySchema,
                           ParsedSchema valueSchema,
                           String topic,
                           boolean parseKey,
                           BufferedReader reader,
                           boolean normalizeSchema,
                           boolean autoRegister,
                           boolean useLatest)

For testing only.

Method Detail

createSerializer

protected abstract SchemaMessageSerializer<T> createSerializer(org.apache.kafka.common.serialization.Serializer keySerializer)

init

public void init(InputStream inputStream,
                 Properties props)

Specified by:

init in interface kafka.common.MessageReader

parseSchema

protected ParsedSchema parseSchema(SchemaRegistryClient schemaRegistry,
                                   String schema,
                                   List<SchemaReference> references)

readMessage

public org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]> readMessage()

Specified by:

readMessage in interface kafka.common.MessageReader

readFrom

protected abstract T readFrom(String jsonString,
                              ParsedSchema schema)

close

public void close()

Specified by:

close in interface kafka.common.MessageReader

getProvider

protected abstract SchemaProvider getProvider()