org.apache.flink.statefun.e2e.common.kafka

Class KafkaProtobufSerializer<T extends com.google.protobuf.Message>

java.lang.Object

org.apache.flink.statefun.e2e.common.kafka.KafkaProtobufSerializer<T>

Type Parameters:

T - type of the Protobuf message.

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, org.apache.kafka.common.serialization.Deserializer<T>, org.apache.kafka.common.serialization.Serializer<T>

public final class KafkaProtobufSerializer<T extends com.google.protobuf.Message>
extends java.lang.Object
implements org.apache.kafka.common.serialization.Serializer<T>, org.apache.kafka.common.serialization.Deserializer<T>

A Kafka Serializer and Deserializer that uses Protobuf for serialization.

Constructor Summary

Constructors

Constructor and Description
KafkaProtobufSerializer(com.google.protobuf.Parser<T> parser)

Method Summary

Modifier and Type	Method and Description
void	close()
void	configure(java.util.Map<java.lang.String,?> map, boolean b)
T	deserialize(java.lang.String s, byte[] bytes)
byte[]	serialize(java.lang.String s, T command)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.kafka.common.serialization.Serializer

serialize

Methods inherited from interface org.apache.kafka.common.serialization.Deserializer

deserialize

Constructor Detail

KafkaProtobufSerializer

public KafkaProtobufSerializer(com.google.protobuf.Parser<T> parser)

Method Detail

serialize

public byte[] serialize(java.lang.String s,
                        T command)

Specified by:

serialize in interface org.apache.kafka.common.serialization.Serializer<T extends com.google.protobuf.Message>

deserialize

public T deserialize(java.lang.String s,
                     byte[] bytes)

Specified by:

deserialize in interface org.apache.kafka.common.serialization.Deserializer<T extends com.google.protobuf.Message>

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface org.apache.kafka.common.serialization.Deserializer<T extends com.google.protobuf.Message>

Specified by:

close in interface org.apache.kafka.common.serialization.Serializer<T extends com.google.protobuf.Message>

configure

public void configure(java.util.Map<java.lang.String,?> map,
                      boolean b)

Specified by:

configure in interface org.apache.kafka.common.serialization.Deserializer<T extends com.google.protobuf.Message>

Specified by:

configure in interface org.apache.kafka.common.serialization.Serializer<T extends com.google.protobuf.Message>