Uses of Interface
org.apache.flink.statefun.sdk.kafka.KafkaEgressSerializer

Packages that use KafkaEgressSerializer

Package	Description
org.apache.flink.statefun.flink.io.kafka.binders.egress.v1
org.apache.flink.statefun.sdk.kafka

Uses of KafkaEgressSerializer in org.apache.flink.statefun.flink.io.kafka.binders.egress.v1

Classes in org.apache.flink.statefun.flink.io.kafka.binders.egress.v1 that implement KafkaEgressSerializer

Modifier and Type	Class and Description
class	GenericKafkaEgressSerializer A KafkaEgressSerializer used solely by Kafka egresses bound by GenericKafkaEgressBinderV1.

Uses of KafkaEgressSerializer in org.apache.flink.statefun.sdk.kafka

Methods in org.apache.flink.statefun.sdk.kafka that return types with arguments of type KafkaEgressSerializer

Modifier and Type	Method and Description
java.lang.Class<? extends KafkaEgressSerializer<OutT>>	KafkaEgressSpec.serializerClass()

Method parameters in org.apache.flink.statefun.sdk.kafka with type arguments of type KafkaEgressSerializer

Modifier and Type	Method and Description
KafkaEgressBuilder<OutT>	KafkaEgressBuilder.withSerializer(java.lang.Class<? extends KafkaEgressSerializer<OutT>> serializer)