Uses of Class
org.apache.flink.streaming.connectors.kafka.FlinkKafkaProducer011

Packages that use FlinkKafkaProducer011

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

Uses of FlinkKafkaProducer011 in org.apache.flink.streaming.connectors.kafka

Methods in org.apache.flink.streaming.connectors.kafka that return FlinkKafkaProducer011

Modifier and Type	Method and Description
FlinkKafkaProducer011<IN>	FlinkKafkaProducer011.ignoreFailuresAfterTransactionTimeout() Disables the propagation of exceptions thrown when committing presumably timed out Kafka transactions during recovery of the job.