Package | Description |
---|---|
org.apache.flink.streaming.connectors.kafka | |
org.apache.flink.streaming.connectors.kafka.internal |
Class and Description |
---|
FlinkKafkaInternalProducer
Internal flink kafka producer.
|
FlinkKafkaProducer
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.
|
Class and Description |
---|
Handover
The Handover is a utility to hand over data (a buffer of records) and exception from a
producer thread to a consumer thread.
|
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() . |
KafkaFetcher
A fetcher that fetches data from Kafka brokers via the Kafka consumer API.
|
KafkaShuffleFetcher.KafkaShuffleElement
An element in a KafkaShuffle.
|
KafkaShuffleFetcher.KafkaShuffleRecord
One value with Type T in a KafkaShuffle.
|
KafkaShuffleFetcher.KafkaShuffleWatermark
A watermark element in a KafkaShuffle.
|
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.