| Class | Description |
|---|---|
| KafkaInputFormat |
Basic input format for reading data from Kafka.
|
| KafkaInputSplit |
InputSplit that represent retrieving data from a single
TopicPartition between the specified start
and end offsets. |
| KafkaRecordReader<K,V> |
A
RecordReader for pulling data from Kafka. |
Copyright © 2017 The Apache Software Foundation. All rights reserved.