Skip navigation links

Back to Flink Website

All Classes

Summary:
Nested |
Enum Constants |
Field |
Method

Detail:
Enum Constants |
Field |
Method

java.lang.Object
- java.lang.Enum<FlinkKafkaProducer011.Semantic>
- - org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011.Semantic

All Implemented Interfaces:

Serializable, Comparable<FlinkKafkaProducer011.Semantic>

Enclosing class:

FlinkKafkaProducer011<IN>
```
public static enum FlinkKafkaProducer011.Semantic
extends Enum<FlinkKafkaProducer011.Semantic>
```
Semantics that can be chosen.
EXACTLY_ONCE
AT_LEAST_ONCE
NONE

Enum Constant Summary

Enum Constants
Enum Constant and Description
`AT_LEAST_ONCE` Semantic.AT_LEAST_ONCE the Flink producer will wait for all outstanding messages in the Kafka buffers to be acknowledged by the Kafka producer on a checkpoint.
`EXACTLY_ONCE` Semantic.EXACTLY_ONCE the Flink producer will write all messages in a Kafka transaction that will be committed to the Kafka on a checkpoint.
`NONE` Semantic.NONE means that nothing will be guaranteed.

Method Summary

All Methods Static Methods Concrete Methods
Modifier and Type	Method and Description
`static FlinkKafkaProducer011.Semantic`	`valueOf(String name)` Returns the enum constant of this type with the specified name.
`static FlinkKafkaProducer011.Semantic[]`	`values()` Returns an array containing the constants of this enum type, in the order they are declared.

Methods inherited from class java.lang.Enum
clone, compareTo, equals, finalize, getDeclaringClass, hashCode, name, ordinal, toString, valueOf

Methods inherited from class java.lang.Object
getClass, notify, notifyAll, wait, wait, wait

- Enum Constant Detail
  - EXACTLY_ONCE
```
public static final FlinkKafkaProducer011.Semantic EXACTLY_ONCE
```
    Semantic.EXACTLY_ONCE the Flink producer will write all messages in a Kafka transaction that will be committed to the Kafka on a checkpoint.
    In this mode FlinkKafkaProducer011 sets up a pool of FlinkKafkaProducer. Between each checkpoint there is created new Kafka transaction, which is being committed on TwoPhaseCommitSinkFunction.notifyCheckpointComplete(long). If checkpoint complete notifications are running late, FlinkKafkaProducer011 can run out of FlinkKafkaProducers in the pool. In that case any subsequent FlinkKafkaProducer011.snapshotState(FunctionSnapshotContext) requests will fail and FlinkKafkaProducer011 will keep using the FlinkKafkaProducer from previous checkpoint. To decrease chances of failing checkpoints there are three options:
  - decrease number of max concurrent checkpoints
  - make checkpoints more reliable (so that they complete faster)
  - increase delay between checkpoints
  - increase size of FlinkKafkaProducers pool

AT_LEAST_ONCE
```
public static final FlinkKafkaProducer011.Semantic AT_LEAST_ONCE
```
Semantic.AT_LEAST_ONCE the Flink producer will wait for all outstanding messages in the Kafka buffers to be acknowledged by the Kafka producer on a checkpoint.

NONE
```
public static final FlinkKafkaProducer011.Semantic NONE
```
Semantic.NONE means that nothing will be guaranteed. Messages can be lost and/or duplicated in case of failure.

Method Detail
- values
```
public static FlinkKafkaProducer011.Semantic[] values()
```
  Returns an array containing the constants of this enum type, in the order they are declared. This method may be used to iterate over the constants as follows:
```
for (FlinkKafkaProducer011.Semantic c : FlinkKafkaProducer011.Semantic.values())
    System.out.println(c);
```
  Returns:
  
  an array containing the constants of this enum type, in the order they are declared
- valueOf
```
public static FlinkKafkaProducer011.Semantic valueOf(String name)
```
  Returns the enum constant of this type with the specified name. The string must match exactly an identifier used to declare an enum constant in this type. (Extraneous whitespace characters are not permitted.)
  
  Parameters:
  
  name - the name of the enum constant to be returned.
  
  Returns:
  
  the enum constant with the specified name
  
  Throws:
  
  IllegalArgumentException - if this enum type has no constant with the specified name
  
  NullPointerException - if the argument is null

Skip navigation links

Back to Flink Website

All Classes

Summary:
Nested |
Enum Constants |
Field |
Method

Detail:
Enum Constants |
Field |
Method

Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.