org.apache.storm.kafka

Interface FailedMsgRetryManager

All Superinterfaces:

Serializable

All Known Implementing Classes:

ExponentialBackoffMsgRetryManager

public interface FailedMsgRetryManager
extends Serializable

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)

Method Detail

prepare

void prepare(SpoutConfig spoutConfig,
             Map stormConf)

Initialization

failed

void failed(Long offset)

Message corresponding to the offset failed in kafka spout.

Parameters:

offset -

acked

void acked(Long offset)

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

Parameters:

offset -

retryStarted

void retryStarted(Long offset)

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

Parameters:

offset -

nextFailedMessageToRetry

Long nextFailedMessageToRetry()

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

Returns:

shouldReEmitMsg

boolean shouldReEmitMsg(Long offset)

Parameters:

offset -

Returns:

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

retryFurther

boolean retryFurther(Long offset)

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

Parameters:

offset -

Returns:

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

clearOffsetsBefore

Set<Long> clearOffsetsBefore(Long kafkaOffset)

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

Parameters:

kafkaOffset -

Returns:

Set of offsets removed.