Package org.apache.storm.kafka.spout

Interface Summary

Interface	Description
Func<V,R>	A simple interface to allow compatibility with non java 8 code bases
KafkaSpoutRetryService	Represents the logic that manages the retrial of failed tuples.
KafkaTupleListener	The KafkaTupleListener handles state changes of a kafka tuple inside a KafkaSpout.
ManualPartitioner	A function used to assign partitions to this spout.
RecordTranslator<K,V>	Translate a ConsumerRecord to a tuple.
SerializableDeserializer<T>	Deprecated Avoid using this class.
TopicFilter

Class Summary

Class	Description
ByTopicRecordTranslator<K,V>	Based off of a given Kafka topic a ConsumerRecord came from it will be translated to a Storm tuple and emitted to a given stream
DefaultRecordTranslator<K,V>
EmptyKafkaTupleListener
KafkaSpout<K,V>
KafkaSpoutConfig<K,V>	KafkaSpoutConfig defines the required configuration to connect a consumer to a consumer group, as well as the subscribing topics
KafkaSpoutConfig.Builder<K,V>
KafkaSpoutMessageId
KafkaSpoutRetryExponentialBackoff	Implementation of KafkaSpoutRetryService using the exponential backoff formula.
KafkaSpoutRetryExponentialBackoff.TimeInterval
KafkaTuple	A list of Values in a tuple that can be routed to a given stream.
ManualPartitionSubscription
NamedSubscription	Deprecated Please use ManualPartitionSubscription with NamedTopicFilter instead
NamedTopicFilter	Filter that returns all partitions for the specified topics.
PatternSubscription	Deprecated Please use ManualPartitionSubscription with PatternTopicFilter instead
PatternTopicFilter	Filter that returns all partitions for topics matching the given Pattern.
RoundRobinManualPartitioner	Assign partitions in a round robin fashion for all spouts, not just the ones that are alive.
SimpleRecordTranslator<K,V>
Subscription	A subscription to kafka.
TopicPartitionComparator	Singleton comparator of TopicPartitions.

Enum Summary

Enum	Description
KafkaSpoutConfig.FirstPollOffsetStrategy	Defines how the KafkaSpout seeks the offset to be used in the first poll to Kafka upon topology deployment.
KafkaSpoutConfig.ProcessingGuarantee	This enum controls when the tuple with the ConsumerRecord for an offset is marked as processed, i.e.