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.