storm.kafka

Class ExponentialBackoffMsgRetryManager

java.lang.Object

storm.kafka.ExponentialBackoffMsgRetryManager

All Implemented Interfaces:

FailedMsgRetryManager

public class ExponentialBackoffMsgRetryManager
extends Object
implements FailedMsgRetryManager

Constructor Summary

Constructors

Constructor and Description
ExponentialBackoffMsgRetryManager(long retryInitialDelayMs, double retryDelayMultiplier, long retryDelayMaxMs)

Method Summary

Modifier and Type	Method and Description
void	acked(Long offset)
Set<Long>	clearInvalidMessages(Long kafkaOffset)
void	failed(Long offset)
Long	nextFailedMessageToRetry()
void	retryStarted(Long offset)
boolean	shouldRetryMsg(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(long retryInitialDelayMs,
                                         double retryDelayMultiplier,
                                         long retryDelayMaxMs)

Method Detail

failed

public void failed(Long offset)

Specified by:

failed in interface FailedMsgRetryManager

acked

public void acked(Long offset)

Specified by:

acked in interface FailedMsgRetryManager

retryStarted

public void retryStarted(Long offset)

Specified by:

retryStarted in interface FailedMsgRetryManager

nextFailedMessageToRetry

public Long nextFailedMessageToRetry()

Specified by:

nextFailedMessageToRetry in interface FailedMsgRetryManager

shouldRetryMsg

public boolean shouldRetryMsg(Long offset)

Specified by:

shouldRetryMsg in interface FailedMsgRetryManager

clearInvalidMessages

public Set<Long> clearInvalidMessages(Long kafkaOffset)

Specified by:

clearInvalidMessages in interface FailedMsgRetryManager