Package | Description |
---|---|
org.apache.flink.statefun.sdk.kafka |
Modifier and Type | Method and Description |
---|---|
static <OutT> KafkaEgressBuilder<OutT> |
KafkaEgressBuilder.forIdentifier(EgressIdentifier<OutT> egressIdentifier) |
KafkaEgressBuilder<OutT> |
KafkaEgressBuilder.withAtLeastOnceProducerSemantics()
KafkaProducerSemantic.AT_LEAST_ONCE the egress will wait for all outstanding messages in the
Kafka buffers to be acknowledged by the Kafka producer on a checkpoint.
|
KafkaEgressBuilder<OutT> |
KafkaEgressBuilder.withExactlyOnceProducerSemantics(java.time.Duration transactionTimeoutDuration)
KafkaProducerSemantic.EXACTLY_ONCE the egress will write all messages in a Kafka transaction
that will be committed to Kafka on a checkpoint.
|
KafkaEgressBuilder<OutT> |
KafkaEgressBuilder.withKafkaAddress(java.lang.String kafkaAddress) |
KafkaEgressBuilder<OutT> |
KafkaEgressBuilder.withKafkaProducerPoolSize(int poolSize) |
KafkaEgressBuilder<OutT> |
KafkaEgressBuilder.withNoProducerSemantics()
KafkaProducerSemantic.NONE means that nothing will be guaranteed.
|
KafkaEgressBuilder<OutT> |
KafkaEgressBuilder.withProperties(java.util.Properties properties)
Configuration properties for the KafkaProducer.
|
KafkaEgressBuilder<OutT> |
KafkaEgressBuilder.withProperty(java.lang.String key,
java.lang.String value)
A configuration property for the KafkaProducer.
|
KafkaEgressBuilder<OutT> |
KafkaEgressBuilder.withSerializer(java.lang.Class<? extends KafkaEgressSerializer<OutT>> serializer) |
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.