Package org.springframework.kafka.retrytopic

Class RetryTopicConfiguration

java.lang.Object

org.springframework.kafka.retrytopic.RetryTopicConfiguration

public class RetryTopicConfiguration
extends java.lang.Object

Contains the provided configuration for the retryable topics. Should be created via the RetryTopicConfigurationBuilder.

Since:

2.7

Author:

Tomaz Fernandes

Method Summary

Modifier and Type	Method	Description
static RetryTopicConfigurationBuilder	builder()
org.springframework.kafka.retrytopic.ListenerContainerFactoryResolver.Configuration	forContainerFactoryResolver()
DeadLetterPublishingRecovererFactory.Configuration	forDeadLetterFactory()
org.springframework.kafka.retrytopic.RetryTopicConfiguration.TopicCreation	forKafkaTopicAutoCreation()
java.util.List<DestinationTopic.Properties>	getDestinationTopicProperties()
org.springframework.kafka.retrytopic.RetryTopicConfigurer.EndpointHandlerMethod	getDltHandlerMethod()
boolean	hasConfigurationForTopics(java.lang.String[] topics)

Methods inherited from class java.lang.Object

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

Method Detail

hasConfigurationForTopics

public boolean hasConfigurationForTopics(java.lang.String[] topics)

forKafkaTopicAutoCreation

public org.springframework.kafka.retrytopic.RetryTopicConfiguration.TopicCreation forKafkaTopicAutoCreation()

forDeadLetterFactory

public DeadLetterPublishingRecovererFactory.Configuration forDeadLetterFactory()

forContainerFactoryResolver

public org.springframework.kafka.retrytopic.ListenerContainerFactoryResolver.Configuration forContainerFactoryResolver()

getDltHandlerMethod

public org.springframework.kafka.retrytopic.RetryTopicConfigurer.EndpointHandlerMethod getDltHandlerMethod()

getDestinationTopicProperties

public java.util.List<DestinationTopic.Properties> getDestinationTopicProperties()

builder

public static RetryTopicConfigurationBuilder builder()