org.apache.flink.statefun.flink.io.kafka.binders.egress.v1

Class GenericKafkaEgressSerializer

java.lang.Object

org.apache.flink.statefun.flink.io.kafka.binders.egress.v1.GenericKafkaEgressSerializer

All Implemented Interfaces:

java.io.Serializable, KafkaEgressSerializer<TypedValue>

public final class GenericKafkaEgressSerializer
extends java.lang.Object
implements KafkaEgressSerializer<TypedValue>

A KafkaEgressSerializer used solely by Kafka egresses bound by GenericKafkaEgressBinderV1.

This serializer expects Protobuf messages of type KafkaProducerRecord, and simply transforms those into Kafka's ProducerRecord.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
GenericKafkaEgressSerializer()

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]>	serialize(TypedValue message) Serializes given element and returns it as a ProducerRecord.

Methods inherited from class java.lang.Object

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

Constructor Detail

GenericKafkaEgressSerializer

public GenericKafkaEgressSerializer()

Method Detail

serialize

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

Description copied from interface: KafkaEgressSerializer

Serializes given element and returns it as a ProducerRecord.

Specified by:

serialize in interface KafkaEgressSerializer<TypedValue>

Parameters:

message - element to be serialized

Returns:

Kafka ProducerRecord