org.apache.flink.statefun.sdk.kafka

Class KafkaProducerSemantic

java.lang.Object

org.apache.flink.statefun.sdk.kafka.KafkaProducerSemantic

Direct Known Subclasses:

KafkaProducerSemantic.AtLeastOnce, KafkaProducerSemantic.ExactlyOnce, KafkaProducerSemantic.NoSemantics

public abstract class KafkaProducerSemantic
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	KafkaProducerSemantic.AtLeastOnce
static class	KafkaProducerSemantic.ExactlyOnce
static class	KafkaProducerSemantic.NoSemantics

Constructor Summary

Constructors

Constructor and Description
KafkaProducerSemantic()

Method Summary

Modifier and Type	Method and Description
KafkaProducerSemantic.AtLeastOnce	asAtLeastOnceSemantic()
KafkaProducerSemantic.ExactlyOnce	asExactlyOnceSemantic()
KafkaProducerSemantic.NoSemantics	asNoSemantic()
static KafkaProducerSemantic	atLeastOnce()
static KafkaProducerSemantic	exactlyOnce(java.time.Duration transactionTimeout)
boolean	isAtLeastOnceSemantic()
boolean	isExactlyOnceSemantic()
boolean	isNoSemantic()
static KafkaProducerSemantic	none()

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaProducerSemantic

public KafkaProducerSemantic()

Method Detail

exactlyOnce

public static KafkaProducerSemantic exactlyOnce(java.time.Duration transactionTimeout)

atLeastOnce

public static KafkaProducerSemantic atLeastOnce()

none

public static KafkaProducerSemantic none()

isExactlyOnceSemantic

public boolean isExactlyOnceSemantic()

asExactlyOnceSemantic

public KafkaProducerSemantic.ExactlyOnce asExactlyOnceSemantic()

isAtLeastOnceSemantic

public boolean isAtLeastOnceSemantic()

asAtLeastOnceSemantic

public KafkaProducerSemantic.AtLeastOnce asAtLeastOnceSemantic()

isNoSemantic

public boolean isNoSemantic()

asNoSemantic

public KafkaProducerSemantic.NoSemantics asNoSemantic()