Uses of Class
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer.Semantic

Packages that use FlinkKafkaProducer.Semantic

Package	Description
org.apache.flink.streaming.connectors.kafka

Uses of FlinkKafkaProducer.Semantic in org.apache.flink.streaming.connectors.kafka

Fields in org.apache.flink.streaming.connectors.kafka declared as FlinkKafkaProducer.Semantic

Modifier and Type	Field and Description
protected FlinkKafkaProducer.Semantic	FlinkKafkaProducer.semantic Semantic chosen for this instance.

Methods in org.apache.flink.streaming.connectors.kafka that return FlinkKafkaProducer.Semantic

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

Constructors in org.apache.flink.streaming.connectors.kafka with parameters of type FlinkKafkaProducer.Semantic

Constructor and Description
FlinkKafkaProducer(String defaultTopic, KafkaSerializationSchema<IN> serializationSchema, Properties producerConfig, FlinkKafkaProducer.Semantic semantic) Creates a FlinkKafkaProducer for a given topic.
FlinkKafkaProducer(String defaultTopic, KafkaSerializationSchema<IN> serializationSchema, Properties producerConfig, FlinkKafkaProducer.Semantic semantic, int kafkaProducersPoolSize) Creates a FlinkKafkaProducer for a given topic.
FlinkKafkaProducer(String topicId, KeyedSerializationSchema<IN> serializationSchema, Properties producerConfig, FlinkKafkaProducer.Semantic semantic) Deprecated. use FlinkKafkaProducer.FlinkKafkaProducer(String, KafkaSerializationSchema, Properties, FlinkKafkaProducer.Semantic)
FlinkKafkaProducer(String defaultTopicId, KeyedSerializationSchema<IN> serializationSchema, Properties producerConfig, Optional<FlinkKafkaPartitioner<IN>> customPartitioner, FlinkKafkaProducer.Semantic semantic, int kafkaProducersPoolSize) Deprecated. use FlinkKafkaProducer.FlinkKafkaProducer(String, KafkaSerializationSchema, Properties, FlinkKafkaProducer.Semantic)
FlinkKafkaProducer(String topicId, SerializationSchema<IN> serializationSchema, Properties producerConfig, FlinkKafkaPartitioner<IN> customPartitioner, FlinkKafkaProducer.Semantic semantic, int kafkaProducersPoolSize) Creates a FlinkKafkaProducer for a given topic.