Class | Description |
---|---|
FlinkKafkaInternalProducer<K,V> |
Internal flink kafka producer.
|
FlinkKafkaProducer<K,V> |
Wrapper around KafkaProducer that allows to resume transactions in case of node failure, which
allows to implement two phase commit algorithm for exactly-once semantic FlinkKafkaProducer.
|
Handover |
The Handover is a utility to hand over data (a buffer of records) and exception from a
producer thread to a consumer thread.
|
Kafka010Fetcher<T> |
A fetcher that fetches data from Kafka brokers via the Kafka 0.10 consumer API.
|
Kafka010PartitionDiscoverer |
A partition discoverer that can be used to discover topics and partitions metadata from Kafka
brokers via the Kafka 0.10 high-level consumer API.
|
KafkaConsumerThread<T> |
The thread the runs the
KafkaConsumer , connecting to the brokers and polling records. |
KafkaFetcher<T> |
A fetcher that fetches data from Kafka brokers via the Kafka consumer API.
|
KafkaPartitionDiscoverer |
A partition discoverer that can be used to discover topics and partitions metadata from Kafka
brokers via the Kafka high-level consumer API.
|
KafkaShuffleFetcher<T> |
Fetch data from Kafka for Kafka Shuffle.
|
KafkaShuffleFetcher.KafkaShuffleElement |
An element in a KafkaShuffle.
|
KafkaShuffleFetcher.KafkaShuffleElementDeserializer<T> |
Deserializer for KafkaShuffleElement.
|
KafkaShuffleFetcher.KafkaShuffleRecord<T> |
One value with Type T in a KafkaShuffle.
|
KafkaShuffleFetcher.KafkaShuffleWatermark |
A watermark element in a KafkaShuffle.
|
TransactionalIdsGenerator |
Class responsible for generating transactional ids to use when communicating with Kafka.
|
Exception | Description |
---|---|
Handover.ClosedException |
An exception thrown by the Handover in the
Handover.pollNext() or Handover.produce(ConsumerRecords) method, after the Handover was closed via Handover.close() . |
Handover.WakeupException |
A special exception thrown bv the Handover in the
Handover.produce(ConsumerRecords) method
when the producer is woken up from a blocking call via Handover.wakeupProducer() . |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.