Uses of Class
org.apache.storm.kafka.spout.KafkaSpoutMessageId
Packages that use KafkaSpoutMessageId
-
Uses of KafkaSpoutMessageId in org.apache.storm.kafka.spout
Methods in org.apache.storm.kafka.spout that return KafkaSpoutMessageIdModifier and TypeMethodDescriptionKafkaSpoutRetryExponentialBackoff.getMessageId(org.apache.kafka.common.TopicPartition tp, long offset) KafkaSpoutRetryService.getMessageId(org.apache.kafka.common.TopicPartition topicPartition, long offset) Gets theKafkaSpoutMessageIdfor the record on the given topic partition and offset.Methods in org.apache.storm.kafka.spout with parameters of type KafkaSpoutMessageIdModifier and TypeMethodDescriptionbooleanKafkaSpoutRetryExponentialBackoff.isReady(KafkaSpoutMessageId msgId) booleanKafkaSpoutRetryService.isReady(KafkaSpoutMessageId msgId) Checks if a specific failedKafkaSpoutMessageIdis ready to be retried, i.e is scheduled and has retry time that is less than current time.booleanKafkaSpoutRetryExponentialBackoff.isScheduled(KafkaSpoutMessageId msgId) booleanKafkaSpoutRetryService.isScheduled(KafkaSpoutMessageId msgId) Checks if a specific failedKafkaSpoutMessageIdis scheduled to be retried.voidEmptyKafkaTupleListener.onAck(KafkaSpoutMessageId msgId) voidKafkaTupleListener.onAck(KafkaSpoutMessageId msgId) Called when a tuple is acked.voidEmptyKafkaTupleListener.onEmit(List<Object> tuple, KafkaSpoutMessageId msgId) voidKafkaTupleListener.onEmit(List<Object> tuple, KafkaSpoutMessageId msgId) Called when the tuple is emitted and auto commit is disabled.voidEmptyKafkaTupleListener.onMaxRetryReached(KafkaSpoutMessageId msgId) voidKafkaTupleListener.onMaxRetryReached(KafkaSpoutMessageId msgId) Called when the maximum number of retries have been reached.voidEmptyKafkaTupleListener.onRetry(KafkaSpoutMessageId msgId) voidKafkaTupleListener.onRetry(KafkaSpoutMessageId msgId) Called when the Kafka spout sets a record for retry.booleanKafkaSpoutRetryExponentialBackoff.remove(KafkaSpoutMessageId msgId) booleanKafkaSpoutRetryService.remove(KafkaSpoutMessageId msgId) Removes a message from the list of messages scheduled for retrial.booleanKafkaSpoutRetryExponentialBackoff.schedule(KafkaSpoutMessageId msgId) booleanKafkaSpoutRetryService.schedule(KafkaSpoutMessageId msgId) Schedules thisKafkaSpoutMessageIdif 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 KafkaSpoutMessageIdModifier and TypeMethodDescriptionvoidOffsetManager.addToAckMsgs(KafkaSpoutMessageId msgId) booleanOffsetManager.contains(KafkaSpoutMessageId msgId)