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:

kafka.common.MessageReader

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 and Description
ProtobufMessageReader() Constructor needed by kafka console producer.

Method Summary

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

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

close, parseSchema, 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$

Constructor Detail

ProtobufMessageReader

public ProtobufMessageReader()

Constructor needed by kafka console producer.

Method Detail

init

public void init(InputStream inputStream,
                 Properties props)

Specified by:

init in interface kafka.common.MessageReader

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>