Package org.apache.storm.kafka.spout.internal
-
Interface Summary Interface Description ClientFactory<K,V> This is here to enable testing. -
Class Summary Class Description ClientFactoryDefault<K,V> CommitMetadata Object representing metadata committed to Kafka.CommitMetadataManager Generates and reads commit metadata.CommonKafkaSpoutConfig<K,V> CommonKafkaSpoutConfig.Builder<K,V,T extends CommonKafkaSpoutConfig.Builder<K,V,T>> OffsetManager Manages acked and committed offsets for a TopicPartition.Timer