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

- Packages that use org.apache.storm.kafka.spout
  Package | Description
  --- | ---
  org.apache.storm.flux.examples |
  org.apache.storm.kafka.spout |
  org.apache.storm.kafka.spout.internal |
  org.apache.storm.sql.kafka |

- Classes in org.apache.storm.kafka.spout used by org.apache.storm.flux.examples
  Class and Description
  Func A simple interface to allow compatibility with non java 8 code bases.
  RecordTranslator Translate a `ConsumerRecord` to a tuple.

- 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.
  FirstPollOffsetStrategy Defines how the spout seeks the offset to be used in the first poll to Kafka upon topology deployment.
  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.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.
  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.
  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.
  RecordTranslator Translate a `ConsumerRecord` to a tuple.
  TopicPartitionComparator Singleton comparator of TopicPartitions.

- Classes in org.apache.storm.kafka.spout used by org.apache.storm.kafka.spout.internal
  Class and Description
  FirstPollOffsetStrategy Defines how the spout seeks the offset to be used in the first poll to Kafka upon topology deployment.
  Func A simple interface to allow compatibility with non java 8 code bases.
  KafkaSpoutConfig.ProcessingGuarantee This enum controls when the tuple with the `ConsumerRecord` for an offset is marked as processed, i.e.
  KafkaSpoutMessageId
  RecordTranslator Translate a `ConsumerRecord` to a tuple.

- Classes in org.apache.storm.kafka.spout used by org.apache.storm.sql.kafka
  Class and Description
  Func A simple interface to allow compatibility with non java 8 code bases.
  RecordTranslator Translate a `ConsumerRecord` to a tuple.

Copyright © 2021 The Apache Software Foundation. All rights reserved.