Package org.springframework.kafka.retrytopic

Class RetryTopicInternalBeanNames

java.lang.Object

org.springframework.kafka.retrytopic.RetryTopicInternalBeanNames

public abstract class RetryTopicInternalBeanNames
extends Object

Contains the internal bean names that will be used by the retryable topic configuration. If you provide a bean of your own with the same name, your instance will be used instead of the default one.

Since:

2.7

Author:

Tomaz Fernandes

Field Summary

Fields

Modifier and Type	Field	Description
static final String	BACKOFF_SLEEPER_BEAN_NAME	Sleeper bean name.
static final String	BACKOFF_TASK_EXECUTOR	TaskExecutor bean name to be used.
static final String	DEAD_LETTER_PUBLISHING_RECOVERER_FACTORY_BEAN_NAME	DeadLetterPublishingRecovererFactory bean name.
static final String	DEFAULT_KAFKA_TEMPLATE_BEAN_NAME	Default KafkaTemplate bean name for publishing to retry topics.
static final String	DEFAULT_LISTENER_FACTORY_BEAN_NAME	The default KafkaListenerContainerFactory bean name that will be looked up if no other is provided.
static final String	DESTINATION_TOPIC_CONTAINER_NAME	DestinationTopicContainer bean name.
static final String	DESTINATION_TOPIC_PROCESSOR_NAME	DestinationTopicProcessor bean name.
static final String	INTERNAL_BACKOFF_CLOCK_BEAN_NAME	The Clock bean name that will be used for backing off partitions.
static final String	INTERNAL_BACKOFF_TIMING_ADJUSTMENT_MANAGER	KafkaConsumerTimingAdjuster bean name.
static final String	INTERNAL_KAFKA_CONSUMER_BACKOFF_MANAGER_FACTORY	KafkaBackOffManagerFactory bean name.
static final String	KAFKA_CONSUMER_BACKOFF_MANAGER	KafkaConsumerBackoffManager bean name.
static final String	LISTENER_CONTAINER_FACTORY_CONFIGURER_NAME	ListenerContainerFactoryConfigurer bean name.
static final String	LISTENER_CONTAINER_FACTORY_RESOLVER_NAME	ListenerContainerFactoryResolver bean name.
static final String	RETRY_TOPIC_BOOTSTRAPPER	RetryTopicBootstrapper bean name.
static final String	RETRY_TOPIC_CONFIGURER	RetryTopicConfigurer bean name.
static final String	RETRY_TOPIC_NAMES_PROVIDER_FACTORY	RetryTopicNamesProviderFactory bean name.

Constructor Summary

Constructors

Constructor	Description
RetryTopicInternalBeanNames()

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

DESTINATION_TOPIC_PROCESSOR_NAME

public static final String DESTINATION_TOPIC_PROCESSOR_NAME

DestinationTopicProcessor bean name.

See Also:

• Constant Field Values

KAFKA_CONSUMER_BACKOFF_MANAGER

public static final String KAFKA_CONSUMER_BACKOFF_MANAGER

KafkaConsumerBackoffManager bean name.

See Also:

• Constant Field Values

LISTENER_CONTAINER_FACTORY_RESOLVER_NAME

public static final String LISTENER_CONTAINER_FACTORY_RESOLVER_NAME

ListenerContainerFactoryResolver bean name.

See Also:

• Constant Field Values

LISTENER_CONTAINER_FACTORY_CONFIGURER_NAME

public static final String LISTENER_CONTAINER_FACTORY_CONFIGURER_NAME

ListenerContainerFactoryConfigurer bean name.

See Also:

• Constant Field Values

DEAD_LETTER_PUBLISHING_RECOVERER_FACTORY_BEAN_NAME

public static final String DEAD_LETTER_PUBLISHING_RECOVERER_FACTORY_BEAN_NAME

DeadLetterPublishingRecovererFactory bean name.

See Also:

• Constant Field Values

DESTINATION_TOPIC_CONTAINER_NAME

public static final String DESTINATION_TOPIC_CONTAINER_NAME

DestinationTopicContainer bean name.

See Also:

• Constant Field Values

DEFAULT_LISTENER_FACTORY_BEAN_NAME

public static final String DEFAULT_LISTENER_FACTORY_BEAN_NAME

The default KafkaListenerContainerFactory bean name that will be looked up if no other is provided.

See Also:

• Constant Field Values

BACKOFF_SLEEPER_BEAN_NAME

public static final String BACKOFF_SLEEPER_BEAN_NAME

Sleeper bean name.

See Also:

• Constant Field Values

BACKOFF_TASK_EXECUTOR

public static final String BACKOFF_TASK_EXECUTOR

TaskExecutor bean name to be used. in the WakingKafkaConsumerTimingAdjuster

See Also:

• Constant Field Values

INTERNAL_BACKOFF_TIMING_ADJUSTMENT_MANAGER

public static final String INTERNAL_BACKOFF_TIMING_ADJUSTMENT_MANAGER

KafkaConsumerTimingAdjuster bean name.

See Also:

• Constant Field Values

INTERNAL_KAFKA_CONSUMER_BACKOFF_MANAGER_FACTORY

public static final String INTERNAL_KAFKA_CONSUMER_BACKOFF_MANAGER_FACTORY

KafkaBackOffManagerFactory bean name.

See Also:

• Constant Field Values

RETRY_TOPIC_NAMES_PROVIDER_FACTORY

public static final String RETRY_TOPIC_NAMES_PROVIDER_FACTORY

RetryTopicNamesProviderFactory bean name.

See Also:

• Constant Field Values

INTERNAL_BACKOFF_CLOCK_BEAN_NAME

public static final String INTERNAL_BACKOFF_CLOCK_BEAN_NAME

The Clock bean name that will be used for backing off partitions.

See Also:

• Constant Field Values

DEFAULT_KAFKA_TEMPLATE_BEAN_NAME

public static final String DEFAULT_KAFKA_TEMPLATE_BEAN_NAME

Default KafkaTemplate bean name for publishing to retry topics.

See Also:

• Constant Field Values

RETRY_TOPIC_BOOTSTRAPPER

public static final String RETRY_TOPIC_BOOTSTRAPPER

RetryTopicBootstrapper bean name.

See Also:

• Constant Field Values

RETRY_TOPIC_CONFIGURER

public static final String RETRY_TOPIC_CONFIGURER

RetryTopicConfigurer bean name.

See Also:

• Constant Field Values

Constructor Details

RetryTopicInternalBeanNames

public RetryTopicInternalBeanNames()