org.apache.flink.statefun.sdk.kafka

Class KafkaProducerSemantic.ExactlyOnce

java.lang.Object

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

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

Enclosing class:

KafkaProducerSemantic

public static class KafkaProducerSemantic.ExactlyOnce
extends KafkaProducerSemantic

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.flink.statefun.sdk.kafka.KafkaProducerSemantic

KafkaProducerSemantic.AtLeastOnce, KafkaProducerSemantic.ExactlyOnce, KafkaProducerSemantic.NoSemantics

Method Summary

Modifier and Type	Method and Description
java.time.Duration	transactionTimeout()

Methods inherited from class org.apache.flink.statefun.sdk.kafka.KafkaProducerSemantic

asAtLeastOnceSemantic, asExactlyOnceSemantic, asNoSemantic, atLeastOnce, exactlyOnce, isAtLeastOnceSemantic, isExactlyOnceSemantic, isNoSemantic, none

Methods inherited from class java.lang.Object

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

Method Detail

transactionTimeout

public java.time.Duration transactionTimeout()