Package org.apache.crunch.kafka

Class Summary

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.