# Uses of Class
org.apache.storm.kafka.spout.KafkaSpoutMessageId

Packages that use KafkaSpoutMessageId
Package
Description
org.apache.storm.kafka.spout
org.apache.storm.kafka.spout.internal

- ## Uses of KafkaSpoutMessageId in org.apache.storm.kafka.spout

  Methods in org.apache.storm.kafka.spout that return KafkaSpoutMessageId
  Modifier and Type
  Method
  Description
  `KafkaSpoutMessageId`
  KafkaSpoutRetryExponentialBackoff.`getMessageId(org.apache.kafka.common.TopicPartition tp, long offset)`
  `KafkaSpoutMessageId`
  KafkaSpoutRetryService.`getMessageId(org.apache.kafka.common.TopicPartition topicPartition, long offset)`
  Gets the `KafkaSpoutMessageId` for the record on the given topic partition and offset.
  Methods in org.apache.storm.kafka.spout with parameters of type KafkaSpoutMessageId
  Modifier and Type
  Method
  Description
  `boolean`
  KafkaSpoutRetryExponentialBackoff.`isReady(KafkaSpoutMessageId msgId)`
  `boolean`
  KafkaSpoutRetryService.`isReady(KafkaSpoutMessageId msgId)`
  Checks if a specific failed `KafkaSpoutMessageId` is ready to be retried, i.e is scheduled and has retry time that is less than current time.
  `boolean`
  KafkaSpoutRetryExponentialBackoff.`isScheduled(KafkaSpoutMessageId msgId)`
  `boolean`
  KafkaSpoutRetryService.`isScheduled(KafkaSpoutMessageId msgId)`
  Checks if a specific failed `KafkaSpoutMessageId` is scheduled to be retried.
  `void`
  EmptyKafkaTupleListener.`onAck(KafkaSpoutMessageId msgId)`
  `void`
  KafkaTupleListener.`onAck(KafkaSpoutMessageId msgId)`
  Called when a tuple is acked.
  `void`
  EmptyKafkaTupleListener.`onEmit(List<Object> tuple, KafkaSpoutMessageId msgId)`
  `void`
  KafkaTupleListener.`onEmit(List<Object> tuple, KafkaSpoutMessageId msgId)`
  Called when the tuple is emitted and auto commit is disabled.
  `void`
  EmptyKafkaTupleListener.`onMaxRetryReached(KafkaSpoutMessageId msgId)`
  `void`
  KafkaTupleListener.`onMaxRetryReached(KafkaSpoutMessageId msgId)`
  Called when the maximum number of retries have been reached.
  `void`
  EmptyKafkaTupleListener.`onRetry(KafkaSpoutMessageId msgId)`
  `void`
  KafkaTupleListener.`onRetry(KafkaSpoutMessageId msgId)`
  Called when the Kafka spout sets a record for retry.
  `boolean`
  KafkaSpoutRetryExponentialBackoff.`remove(KafkaSpoutMessageId msgId)`
  `boolean`
  KafkaSpoutRetryService.`remove(KafkaSpoutMessageId msgId)`
  Removes a message from the list of messages scheduled for retrial.
  `boolean`
  KafkaSpoutRetryExponentialBackoff.`schedule(KafkaSpoutMessageId msgId)`
  `boolean`
  KafkaSpoutRetryService.`schedule(KafkaSpoutMessageId msgId)`
  Schedules this `KafkaSpoutMessageId` if not yet scheduled, or updates retry time if it has already been scheduled.

- ## Uses of KafkaSpoutMessageId in org.apache.storm.kafka.spout.internal

  Methods in org.apache.storm.kafka.spout.internal with parameters of type KafkaSpoutMessageId
  Modifier and Type
  Method
  Description
  `void`
  OffsetManager.`addToAckMsgs(KafkaSpoutMessageId msgId)`
  `boolean`
  OffsetManager.`contains(KafkaSpoutMessageId msgId)`