Package org.apache.storm.kafka.spout.internal

Interface Summary

Interface	Description
KafkaConsumerFactory<K,V>	This is here to enable testing

Class Summary

Class	Description
CommitMetadata	Object representing metadata committed to Kafka.
CommitMetadataManager	Generates and reads commit metadata.
KafkaConsumerFactoryDefault<K,V>
OffsetManager	Manages acked and committed offsets for a TopicPartition.
Timer