# Package org.apache.storm.kafka.spout

package org.apache.storm.kafka.spout

- Related Packages
  Package
  Description
  org.apache.storm.kafka.spout.internal
  org.apache.storm.kafka.spout.metrics2
  org.apache.storm.kafka.spout.subscription
  org.apache.storm.kafka.spout.trident
- 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
  FirstPollOffsetStrategy
  Defines how the spout seeks the offset to be used in the first poll to Kafka upon topology deployment.
  Func<V,R>
  A simple interface to allow compatibility with non java 8 code bases.
  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>
  KafkaSpoutConfig.ProcessingGuarantee
  This enum controls when the tuple with the `ConsumerRecord` for an offset is marked as processed, i.e.
  KafkaSpoutMessageId
  KafkaSpoutRetryExponentialBackoff
  Implementation of `KafkaSpoutRetryService` using the exponential backoff formula.
  KafkaSpoutRetryExponentialBackoff.TimeInterval
  KafkaSpoutRetryService
  Represents the logic that manages the retrial of failed tuples.
  KafkaSpoutTestBolt
  KafkaSpoutTopologyMainNamedTopics
  This example sets up 3 topologies to put data in Kafka via the KafkaBolt, and shows how to set up a topology that reads from some Kafka topics using the KafkaSpout.
  KafkaSpoutTopologyMainWildcardTopics
  This example is similar to `KafkaSpoutTopologyMainNamedTopics`, but demonstrates subscribing to Kafka topics with a regex.
  KafkaTuple
  A list of Values in a tuple that can be routed to a given stream: `RecordTranslator.apply(org.apache.kafka.clients.consumer.ConsumerRecord<K, V>)`.
  KafkaTupleListener
  The KafkaTupleListener handles state changes of a kafka tuple inside a KafkaSpout.
  RecordTranslator<K,V>
  Translate a `ConsumerRecord` to a tuple.
  SimpleRecordTranslator<K,V>
  TopicPartitionComparator
  Singleton comparator of TopicPartitions.