Package | Description |
---|---|
org.apache.flink.statefun.sdk.kafka |
Modifier and Type | Class and Description |
---|---|
static class |
KafkaProducerSemantic.AtLeastOnce |
static class |
KafkaProducerSemantic.ExactlyOnce |
static class |
KafkaProducerSemantic.NoSemantics |
Modifier and Type | Method and Description |
---|---|
static KafkaProducerSemantic |
KafkaProducerSemantic.atLeastOnce() |
static KafkaProducerSemantic |
KafkaProducerSemantic.exactlyOnce(java.time.Duration transactionTimeout) |
static KafkaProducerSemantic |
KafkaProducerSemantic.none() |
KafkaProducerSemantic |
KafkaEgressSpec.semantic() |
Modifier and Type | Method and Description |
---|---|
KafkaEgressBuilder<OutT> |
KafkaEgressBuilder.withProducerSemantic(KafkaProducerSemantic producerSemantic) |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.