Class | 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.
|
Kafka010Fetcher<T> |
A fetcher that fetches data from Kafka brokers via the Kafka 0.10 consumer API.
|
Kafka09Fetcher<T> |
A fetcher that fetches data from Kafka brokers via the Kafka 0.9 consumer API.
|
KafkaConsumerCallBridge |
The ConsumerCallBridge simply calls methods on the
KafkaConsumer . |
KafkaConsumerCallBridge010 |
The ConsumerCallBridge simply calls the
KafkaConsumer.assign(java.util.Collection) method. |
KafkaConsumerThread |
The thread the runs the
KafkaConsumer , connecting to the brokers and polling records. |
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–2017 The Apache Software Foundation. All rights reserved.