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 theKafkaSpoutMessageId
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 failedKafkaSpoutMessageId
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 failedKafkaSpoutMessageId
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 thisKafkaSpoutMessageId
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)
-