Package org.apache.storm.kafka.spout.internal
package org.apache.storm.kafka.spout.internal
-
ClassDescriptionClientFactory<K,
V> This is here to enable testing.ClientFactoryDefault<K,V> Object representing metadata committed to Kafka.Generates and reads commit metadata.CommonKafkaSpoutConfig.Builder<K,V, T extends CommonKafkaSpoutConfig.Builder<K, V, T>> Manages acked and committed offsets for a TopicPartition.