Package org.springframework.kafka.retrytopic

Class RetryTopicConfigurationSupport.KafkaBackOffManagerConfigurer

java.lang.Object

org.springframework.kafka.retrytopic.RetryTopicConfigurationSupport.KafkaBackOffManagerConfigurer

Enclosing class:

RetryTopicConfigurationSupport

public static class RetryTopicConfigurationSupport.KafkaBackOffManagerConfigurer
extends Object

Configure the KafkaConsumerBackoffManager instance.

Constructor Summary

Constructors

Constructor	Description
KafkaBackOffManagerConfigurer()

Method Summary

Modifier and Type	Method	Description
RetryTopicConfigurationSupport.KafkaBackOffManagerConfigurer	disableTimingAdjustment()	Disable timing adjustment for the delays.
RetryTopicConfigurationSupport.KafkaBackOffManagerConfigurer	setClock(Clock clock)	Set the Clock instance to be used with the KafkaConsumerBackoffManager.
RetryTopicConfigurationSupport.KafkaBackOffManagerConfigurer	setMaxThreadPoolSize(int maxThreadPoolSize)	Set the maximum thread pool size to be used by the WakingKafkaConsumerTimingAdjuster.

Methods inherited from class java.lang.Object

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

Constructor Details

KafkaBackOffManagerConfigurer

public KafkaBackOffManagerConfigurer()

Method Details

disableTimingAdjustment

public RetryTopicConfigurationSupport.KafkaBackOffManagerConfigurer disableTimingAdjustment()

Disable timing adjustment for the delays. By choosing this option records won't be processed exactly at the proper time. It's guaranteed however that records won't be processed before their due time.

Returns:

the configurer.

See Also:

• WakingKafkaConsumerTimingAdjuster

setMaxThreadPoolSize

public RetryTopicConfigurationSupport.KafkaBackOffManagerConfigurer setMaxThreadPoolSize(int maxThreadPoolSize)

Set the maximum thread pool size to be used by the WakingKafkaConsumerTimingAdjuster. This KafkaConsumerTimingAdjuster implementation spawns threads that will sleep for a calculated time, and after that will Consumer.wakeup() the consumer, in order to improve delay precision.

Parameters:

maxThreadPoolSize - the maximum thread pool size.

Returns:

the configurer.

setClock

public RetryTopicConfigurationSupport.KafkaBackOffManagerConfigurer setClock(Clock clock)

Set the Clock instance to be used with the KafkaConsumerBackoffManager.

Parameters:

clock - the clock instance.

Returns:

the configurer.