Class | Description |
---|---|
KafkaSource |
A Crunch Source that will retrieve events from Kafka given start and end offsets.
|
KafkaSource.BytesDeserializer |
Basic
Deserializer which simply wraps the payload as a BytesWritable . |
KafkaUtils |
Simple utilities for retrieving offset and Kafka information to assist in setting up and configuring a
KafkaSource instance. |
Copyright © 2017 The Apache Software Foundation. All rights reserved.