Package | Description |
---|---|
org.apache.flink.streaming.connectors.kafka | |
org.apache.flink.streaming.connectors.kafka.shuffle |
Modifier and Type | Method and Description |
---|---|
FlinkKafkaProducer<IN> |
FlinkKafkaProducer.ignoreFailuresAfterTransactionTimeout()
Deprecated.
Disables the propagation of exceptions thrown when committing presumably timed out Kafka
transactions during recovery of the job.
|
Modifier and Type | Class and Description |
---|---|
class |
FlinkKafkaShuffleProducer<IN,KEY>
Flink Kafka Shuffle Producer Function.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.