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