Package | Description |
---|---|
org.apache.flink.streaming.connectors.kafka | |
org.apache.flink.streaming.connectors.kafka.shuffle | |
org.apache.flink.streaming.connectors.kafka.table |
Modifier and Type | Method and Description |
---|---|
FlinkKafkaProducer<IN> |
FlinkKafkaProducer.ignoreFailuresAfterTransactionTimeout()
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.
|
Modifier and Type | Method and Description |
---|---|
protected FlinkKafkaProducer<RowData> |
KafkaDynamicSink.createKafkaProducer(SerializationSchema<RowData> keySerialization,
SerializationSchema<RowData> valueSerialization) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.