|Class and Description|
The Handover is a utility to hand over data (a buffer of records) and exception from a producer thread to a consumer thread.
A fetcher that fetches data from Kafka brokers via the Kafka 0.9 consumer API.
A partition discoverer that can be used to discover topics and partitions metadata from Kafka brokers via the Kafka 0.9 high-level consumer API.
The ConsumerCallBridge simply calls methods on the
The ConsumerCallBridge simply calls the
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.