Package org.springframework.kafka.retrytopic

Class RetryTopicInternalBeanNames

java.lang.Object

org.springframework.kafka.retrytopic.RetryTopicInternalBeanNames

public abstract class RetryTopicInternalBeanNames
extends java.lang.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 java.lang.String	BACKOFF_SLEEPER_BEAN_NAME	Sleeper bean name.
static java.lang.String	BACKOFF_TASK_EXECUTOR	TaskExecutor bean name to be used.
static java.lang.String	DEAD_LETTER_PUBLISHING_RECOVERER_PROVIDER_NAME	DeadLetterPublishingRecovererFactory bean name.
static java.lang.String	DEFAULT_KAFKA_TEMPLATE_BEAN_NAME	Default KafkaTemplate bean name for publishing to retry topics.
static java.lang.String	DEFAULT_LISTENER_FACTORY_BEAN_NAME	The default KafkaListenerContainerFactory bean name that will be looked up if no other is provided.
static java.lang.String	DESTINATION_TOPIC_CONTAINER_NAME	DestinationTopicContainer bean name.
static java.lang.String	DESTINATION_TOPIC_PROCESSOR_NAME	DestinationTopicProcessor bean name.
static java.lang.String	INTERNAL_BACKOFF_CLOCK_BEAN_NAME	The Clock bean name that will be used for backing off partitions.
static java.lang.String	INTERNAL_BACKOFF_TIMING_ADJUSTMENT_MANAGER	KafkaConsumerTimingAdjuster bean name.
static java.lang.String	INTERNAL_KAFKA_CONSUMER_BACKOFF_MANAGER_FACTORY	KafkaBackOffManagerFactory bean name.
static java.lang.String	KAFKA_CONSUMER_BACKOFF_MANAGER	KafkaConsumerBackoffManager bean name.
static java.lang.String	LISTENER_CONTAINER_FACTORY_CONFIGURER_NAME	ListenerContainerFactoryConfigurer bean name.
static java.lang.String	LISTENER_CONTAINER_FACTORY_RESOLVER_NAME	ListenerContainerFactoryResolver bean name.
static java.lang.String	RETRY_TOPIC_BOOTSTRAPPER	RetryTopicBootstrapper bean name.
static java.lang.String	RETRY_TOPIC_CONFIGURER	RetryTopicConfigurer bean name.
static java.lang.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 Detail

DESTINATION_TOPIC_PROCESSOR_NAME

public static final java.lang.String DESTINATION_TOPIC_PROCESSOR_NAME

DestinationTopicProcessor bean name.

See Also:

Constant Field Values

KAFKA_CONSUMER_BACKOFF_MANAGER

public static final java.lang.String KAFKA_CONSUMER_BACKOFF_MANAGER

KafkaConsumerBackoffManager bean name.

See Also:

Constant Field Values

LISTENER_CONTAINER_FACTORY_RESOLVER_NAME

public static final java.lang.String LISTENER_CONTAINER_FACTORY_RESOLVER_NAME

ListenerContainerFactoryResolver bean name.

See Also:

Constant Field Values

LISTENER_CONTAINER_FACTORY_CONFIGURER_NAME

public static final java.lang.String LISTENER_CONTAINER_FACTORY_CONFIGURER_NAME

ListenerContainerFactoryConfigurer bean name.

See Also:

Constant Field Values

DEAD_LETTER_PUBLISHING_RECOVERER_PROVIDER_NAME

public static final java.lang.String DEAD_LETTER_PUBLISHING_RECOVERER_PROVIDER_NAME

DeadLetterPublishingRecovererFactory bean name.

See Also:

Constant Field Values

DESTINATION_TOPIC_CONTAINER_NAME

public static final java.lang.String DESTINATION_TOPIC_CONTAINER_NAME

DestinationTopicContainer bean name.

See Also:

Constant Field Values

DEFAULT_LISTENER_FACTORY_BEAN_NAME

public static final java.lang.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 java.lang.String BACKOFF_SLEEPER_BEAN_NAME

Sleeper bean name.

See Also:

Constant Field Values

BACKOFF_TASK_EXECUTOR

public static final java.lang.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 java.lang.String INTERNAL_BACKOFF_TIMING_ADJUSTMENT_MANAGER

KafkaConsumerTimingAdjuster bean name.

See Also:

Constant Field Values

INTERNAL_KAFKA_CONSUMER_BACKOFF_MANAGER_FACTORY

public static final java.lang.String INTERNAL_KAFKA_CONSUMER_BACKOFF_MANAGER_FACTORY

KafkaBackOffManagerFactory bean name.

See Also:

Constant Field Values

RETRY_TOPIC_NAMES_PROVIDER_FACTORY

public static final java.lang.String RETRY_TOPIC_NAMES_PROVIDER_FACTORY

RetryTopicNamesProviderFactory bean name.

See Also:

Constant Field Values

INTERNAL_BACKOFF_CLOCK_BEAN_NAME

public static final java.lang.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 java.lang.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 java.lang.String RETRY_TOPIC_BOOTSTRAPPER

RetryTopicBootstrapper bean name.

See Also:

Constant Field Values

RETRY_TOPIC_CONFIGURER

public static final java.lang.String RETRY_TOPIC_CONFIGURER

RetryTopicConfigurer bean name.

See Also:

Constant Field Values

Constructor Detail

RetryTopicInternalBeanNames

public RetryTopicInternalBeanNames()