org.apache.storm.kafka

Class ExponentialBackoffMsgRetryManager

java.lang.Object

org.apache.storm.kafka.ExponentialBackoffMsgRetryManager

All Implemented Interfaces:

Serializable, FailedMsgRetryManager

public class ExponentialBackoffMsgRetryManager
extends Object
implements FailedMsgRetryManager

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ExponentialBackoffMsgRetryManager()

Method Summary

Modifier and Type	Method and Description
void	acked(Long offset) Message corresponding to the offset, was acked to kafka spout.
Set<Long>	clearOffsetsBefore(Long kafkaOffset) Clear any offsets before kafkaOffset.
void	failed(Long offset) Message corresponding to the offset failed in kafka spout.
Long	nextFailedMessageToRetry() The offset of message, which is to be re-emitted.
void	prepare(SpoutConfig spoutConfig, Map stormConf) Initialization
boolean	retryFurther(Long offset) Spout will clean up the state for this offset if false is returned.
void	retryStarted(Long offset) Message corresponding to the offset, has been re-emitted and under transit.
boolean	shouldReEmitMsg(Long offset)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ExponentialBackoffMsgRetryManager

public ExponentialBackoffMsgRetryManager()

Method Detail

prepare

public void prepare(SpoutConfig spoutConfig,
                    Map stormConf)

Description copied from interface: FailedMsgRetryManager

Initialization

Specified by:

prepare in interface FailedMsgRetryManager

failed

public void failed(Long offset)

Description copied from interface: FailedMsgRetryManager

Message corresponding to the offset failed in kafka spout.

Specified by:

failed in interface FailedMsgRetryManager

acked

public void acked(Long offset)

Description copied from interface: FailedMsgRetryManager

Message corresponding to the offset, was acked to kafka spout.

Specified by:

acked in interface FailedMsgRetryManager

retryStarted

public void retryStarted(Long offset)

Description copied from interface: FailedMsgRetryManager

Message corresponding to the offset, has been re-emitted and under transit.

Specified by:

retryStarted in interface FailedMsgRetryManager

nextFailedMessageToRetry

public Long nextFailedMessageToRetry()

Description copied from interface: FailedMsgRetryManager

The offset of message, which is to be re-emitted. Spout will fetch messages starting from this offset and resend them, except completed messages.

Specified by:

nextFailedMessageToRetry in interface FailedMsgRetryManager

Returns:

shouldReEmitMsg

public boolean shouldReEmitMsg(Long offset)

Specified by:

shouldReEmitMsg in interface FailedMsgRetryManager

Returns:

True if the message corresponding to the offset should be emitted NOW. False otherwise.

retryFurther

public boolean retryFurther(Long offset)

Description copied from interface: FailedMsgRetryManager

Spout will clean up the state for this offset if false is returned.

Specified by:

retryFurther in interface FailedMsgRetryManager

Returns:

True if the message will be retried again. False otherwise.

clearOffsetsBefore

public Set<Long> clearOffsetsBefore(Long kafkaOffset)

Description copied from interface: FailedMsgRetryManager

Clear any offsets before kafkaOffset. These offsets are no longer available in kafka.

Specified by:

clearOffsetsBefore in interface FailedMsgRetryManager

Returns:

Set of offsets removed.