org.apache.flink.statefun.sdk.kafka

Class KafkaIngressSpec<T>

java.lang.Object

org.apache.flink.statefun.sdk.kafka.KafkaIngressSpec<T>

All Implemented Interfaces:

IngressSpec<T>

public class KafkaIngressSpec<T>
extends java.lang.Object
implements IngressSpec<T>

Method Summary

Modifier and Type	Method and Description
KafkaIngressDeserializer<T>	deserializer()
IngressIdentifier<T>	id() Returns the unique identifier of the ingress.
java.util.Properties	properties()
KafkaIngressStartupPosition	startupPosition()
java.util.List<java.lang.String>	topics()
IngressType	type() Returns the type of the ingress.

Methods inherited from class java.lang.Object

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

Method Detail

id

public IngressIdentifier<T> id()

Description copied from interface: IngressSpec

Returns the unique identifier of the ingress.

Specified by:

id in interface IngressSpec<T>

Returns:

the unique identifier of the ingress.

type

public IngressType type()

Description copied from interface: IngressSpec

Returns the type of the ingress.

Specified by:

type in interface IngressSpec<T>

Returns:

the type of the ingress.

properties

public java.util.Properties properties()

topics

public java.util.List<java.lang.String> topics()

deserializer

public KafkaIngressDeserializer<T> deserializer()

startupPosition

public KafkaIngressStartupPosition startupPosition()