Package io.confluent.kafka.formatter.protobuf

Class ProtobufMessageReader

java.lang.Object

io.confluent.kafka.formatter.SchemaMessageReader<com.google.protobuf.Message>

io.confluent.kafka.formatter.protobuf.ProtobufMessageReader

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.kafka.common.Configurable, org.apache.kafka.tools.api.RecordReader

public class ProtobufMessageReader
extends SchemaMessageReader<com.google.protobuf.Message>

Example To use ProtobufMessageReader, first make sure that Zookeeper, Kafka and schema registry server are all started. Second, make sure the jar for ProtobufMessageReader and its dependencies are included in the classpath of kafka-console-producer.sh. Then run the following command.

Send Protobuf record as value. bin/kafka-console-producer.sh --bootstrap-server localhost:9092 --topic t1 \ --line-reader io.confluent.kafka.formatter.ProtobufMessageReader \ --property schema.registry.url=http://localhost:8081 \ --property value.schema='syntax = "proto3"; message MyRecord { string f1 = 1; }'

In the shell, type in the following. {"f1": "value1"}

Field Summary

Fields inherited from class io.confluent.kafka.formatter.SchemaMessageReader

KEY_SCHEMA, keySchema, VALUE_SCHEMA, valueSchema

Constructor Summary

Constructors

Constructor	Description
ProtobufMessageReader()	Constructor needed by kafka console producer.

Method Summary

Modifier and Type	Method	Description
protected SchemaMessageSerializer<com.google.protobuf.Message>	createSerializer(org.apache.kafka.common.serialization.Serializer keySerializer)
protected SchemaProvider	getProvider()
void	init(Properties props)
protected com.google.protobuf.Message	readFrom(String jsonString, ParsedSchema schema)

Methods inherited from class io.confluent.kafka.formatter.SchemaMessageReader

close, configure, parseSchema, readRecords

Methods inherited from class java.lang.Object

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

Constructor Details

ProtobufMessageReader

public ProtobufMessageReader()

Constructor needed by kafka console producer.

Method Details

init

public void init(Properties props)

Overrides:

init in class SchemaMessageReader<com.google.protobuf.Message>

createSerializer

protected SchemaMessageSerializer<com.google.protobuf.Message> createSerializer(org.apache.kafka.common.serialization.Serializer keySerializer)

Specified by:

createSerializer in class SchemaMessageReader<com.google.protobuf.Message>

getProvider

protected SchemaProvider getProvider()

Specified by:

getProvider in class SchemaMessageReader<com.google.protobuf.Message>

readFrom

protected com.google.protobuf.Message readFrom(String jsonString,
 ParsedSchema schema)

Specified by:

readFrom in class SchemaMessageReader<com.google.protobuf.Message>