org.apache.flink.statefun.sdk.kafka

Class KafkaEgressSpec<OutT>

java.lang.Object

org.apache.flink.statefun.sdk.kafka.KafkaEgressSpec<OutT>

All Implemented Interfaces:

EgressSpec<OutT>

public final class KafkaEgressSpec<OutT>
extends java.lang.Object
implements EgressSpec<OutT>

Method Summary

Modifier and Type	Method and Description
EgressIdentifier<OutT>	id() Returns the unique identifier of the egress.
java.lang.String	kafkaAddress()
int	kafkaProducerPoolSize()
java.util.Properties	properties()
KafkaProducerSemantic	semantic()
java.lang.Class<? extends KafkaEgressSerializer<OutT>>	serializerClass()
EgressType	type() Returns the type of the egress.

Methods inherited from class java.lang.Object

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

Method Detail

id

public EgressIdentifier<OutT> id()

Description copied from interface: EgressSpec

Returns the unique identifier of the egress.

Specified by:

id in interface EgressSpec<OutT>

Returns:

the unique identifier of the egress.

type

public EgressType type()

Description copied from interface: EgressSpec

Returns the type of the egress.

Specified by:

type in interface EgressSpec<OutT>

Returns:

the type of the egress.

serializerClass

public java.lang.Class<? extends KafkaEgressSerializer<OutT>> serializerClass()

kafkaAddress

public java.lang.String kafkaAddress()

properties

public java.util.Properties properties()

kafkaProducerPoolSize

public int kafkaProducerPoolSize()

semantic

public KafkaProducerSemantic semantic()