Uses of Package
org.apache.storm.kafka.spout

Packages that use org.apache.storm.kafka.spout

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

Classes in org.apache.storm.kafka.spout used by org.apache.storm.kafka.spout

Class and Description
ByTopicRecordTranslator 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
Func A simple interface to allow compatibility with non java 8 code bases
KafkaSpoutConfig KafkaSpoutConfig defines the required configuration to connect a consumer to a consumer group, as well as the subscribing topics
KafkaSpoutConfig.Builder
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.
KafkaSpoutMessageId
KafkaSpoutRetryExponentialBackoff.TimeInterval
KafkaSpoutRetryService Represents the logic that manages the retrial of failed tuples.
KafkaTuple A list of Values in a tuple that can be routed to a given stream.
KafkaTupleListener The KafkaTupleListener handles state changes of a kafka tuple inside a KafkaSpout.
ManualPartitioner A function used to assign partitions to this spout.
RecordTranslator Translate a ConsumerRecord to a tuple.
SerializableDeserializer Deprecated. Avoid using this class. Use KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object) with ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG instead
Subscription A subscription to kafka.
TopicFilter
TopicPartitionComparator Singleton comparator of TopicPartitions.

Classes in org.apache.storm.kafka.spout used by org.apache.storm.kafka.spout.internal

Class and Description
KafkaSpoutConfig KafkaSpoutConfig defines the required configuration to connect a consumer to a consumer group, as well as the subscribing topics
KafkaSpoutConfig.ProcessingGuarantee This enum controls when the tuple with the ConsumerRecord for an offset is marked as processed, i.e.
KafkaSpoutMessageId

Classes in org.apache.storm.kafka.spout used by org.apache.storm.kafka.spout.trident

Class and Description
KafkaSpoutConfig KafkaSpoutConfig defines the required configuration to connect a consumer to a consumer group, as well as the subscribing topics

Classes in org.apache.storm.kafka.spout used by org.apache.storm.kafka.trident

Class and Description
KafkaSpoutConfig KafkaSpoutConfig defines the required configuration to connect a consumer to a consumer group, as well as the subscribing topics
KafkaSpoutRetryService Represents the logic that manages the retrial of failed tuples.