Package com.broadleafcommerce.common.messaging.retry.blocking

Class BlockingFixedRetryInfo.Kafka

java.lang.Object

com.broadleafcommerce.common.messaging.retry.blocking.BlockingFixedRetryInfo.Kafka

Enclosing class:

BlockingFixedRetryInfo

public static class BlockingFixedRetryInfo.Kafka
extends Object

Constructor Summary

Constructors

Constructor	Description
Kafka()

Method Summary

Modifier and Type	Method	Description
protected boolean	canEqual(Object other)
boolean	equals(Object o)
int	hashCode()
boolean	isSeekToCurrentRecordOnFailure()	Optional.
void	setSeekToCurrentRecordOnFailure(boolean seekToCurrentRecordOnFailure)	Optional.
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

Kafka

public Kafka()

Method Details

isSeekToCurrentRecordOnFailure

public boolean isSeekToCurrentRecordOnFailure()

Optional. When using the kafka binder, whether failures will be bubbled to the container in combination with a backoff duration, which facilitates seek to current record for retry. This behavior will prevent a possible kafka re-balance in the event the backoff exceeds the poll interval. If false, standard spring retry will be used, in which case, care should be taken that the aggregate of all processing, retries, and delays for a poll of records does not exceed the consumer's max.poll.interval.ms (default 5 minutes) property. Default is true. If not using the kafka binder, this setting has no effect.

setSeekToCurrentRecordOnFailure

public void setSeekToCurrentRecordOnFailure(boolean seekToCurrentRecordOnFailure)

Optional. When using the kafka binder, whether failures will be bubbled to the container in combination with a backoff duration, which facilitates seek to current record for retry. This behavior will prevent a possible kafka re-balance in the event the backoff exceeds the poll interval. If false, standard spring retry will be used, in which case, care should be taken that the aggregate of all processing, retries, and delays for a poll of records does not exceed the consumer's max.poll.interval.ms (default 5 minutes) property. Default is true. If not using the kafka binder, this setting has no effect.

equals

public boolean equals(Object o)

Overrides:

equals in class Object

canEqual

protected boolean canEqual(Object other)

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object