Class KafkaProperties.Retry.Topic

java.lang.Object

org.springframework.boot.kafka.autoconfigure.KafkaProperties.Retry.Topic

Enclosing class:

KafkaProperties.Retry

public static class KafkaProperties.Retry.Topic
extends Object

Properties for non-blocking, topic-based retries.

Since:

4.0.0

Author:

Gary Russell, Stephane Nicoll, Artem Bilan, Nakul Mishra, Tomaz Fernandes, Andy Wilkinson, Scott Frederick, Yanming Zhou

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	KafkaProperties.Retry.Topic.Backoff

Constructor Summary

Constructors

Constructor	Description
Topic()

Method Summary

Modifier and Type	Method	Description
int	getAttempts()
KafkaProperties.Retry.Topic.Backoff	getBackoff()
Duration	getDelay()	Deprecated, for removal: This API element is subject to removal in a future version.
Duration	getMaxDelay()	Deprecated, for removal: This API element is subject to removal in a future version.
double	getMultiplier()	Deprecated, for removal: This API element is subject to removal in a future version.
boolean	isEnabled()
boolean	isRandomBackOff()	Deprecated, for removal: This API element is subject to removal in a future version.
void	setAttempts(int attempts)
void	setDelay(Duration delay)	Deprecated, for removal: This API element is subject to removal in a future version.
void	setEnabled(boolean enabled)
void	setMaxDelay(Duration maxDelay)	Deprecated, for removal: This API element is subject to removal in a future version.
void	setMultiplier(double multiplier)	Deprecated, for removal: This API element is subject to removal in a future version.
void	setRandomBackOff(boolean randomBackOff)	Deprecated, for removal: This API element is subject to removal in a future version.

Methods inherited from class java.lang.Object

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

Constructor Details

Topic

public Topic()

Method Details

isEnabled

public boolean isEnabled()

setEnabled

public void setEnabled(boolean enabled)

getAttempts

public int getAttempts()

setAttempts

public void setAttempts(int attempts)

getDelay

@DeprecatedConfigurationProperty(replacement="spring.kafka.retry.topic.backoff.delay",
                                 since="3.4.0")
@Deprecated(since="3.4.0",
            forRemoval=true)
public Duration getDelay()

Deprecated, for removal: This API element is subject to removal in a future version.

setDelay

@Deprecated(since="3.4.0",
            forRemoval=true)
public void setDelay(Duration delay)

Deprecated, for removal: This API element is subject to removal in a future version.

getMultiplier

@DeprecatedConfigurationProperty(replacement="spring.kafka.retry.topic.backoff.multiplier",
                                 since="3.4.0")
@Deprecated(since="3.4.0",
            forRemoval=true)
public double getMultiplier()

Deprecated, for removal: This API element is subject to removal in a future version.

setMultiplier

@Deprecated(since="3.4.0",
            forRemoval=true)
public void setMultiplier(double multiplier)

Deprecated, for removal: This API element is subject to removal in a future version.

getMaxDelay

@DeprecatedConfigurationProperty(replacement="spring.kafka.retry.topic.backoff.maxDelay",
                                 since="3.4.0")
@Deprecated(since="3.4.0",
            forRemoval=true)
public Duration getMaxDelay()

Deprecated, for removal: This API element is subject to removal in a future version.

setMaxDelay

@Deprecated(since="3.4.0",
            forRemoval=true)
public void setMaxDelay(Duration maxDelay)

Deprecated, for removal: This API element is subject to removal in a future version.

isRandomBackOff

@DeprecatedConfigurationProperty(replacement="spring.kafka.retry.topic.backoff.random",
                                 since="3.4.0")
@Deprecated(since="3.4.0",
            forRemoval=true)
public boolean isRandomBackOff()

Deprecated, for removal: This API element is subject to removal in a future version.

setRandomBackOff

@Deprecated(since="3.4.0",
            forRemoval=true)
public void setRandomBackOff(boolean randomBackOff)

Deprecated, for removal: This API element is subject to removal in a future version.

getBackoff

public KafkaProperties.Retry.Topic.Backoff getBackoff()