Package org.springframework.kafka.retrytopic

Class RetryTopicConfiguration

java.lang.Object

org.springframework.kafka.retrytopic.RetryTopicConfiguration

public class RetryTopicConfiguration
extends Object

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

Since:

2.7

Author:

Tomaz Fernandes, Gary Russell, Wang Zhiyang

Method Summary

Modifier and Type	Method	Description
org.springframework.kafka.retrytopic.ListenerContainerFactoryResolver.Configuration	forContainerFactoryResolver()
org.springframework.kafka.retrytopic.RetryTopicConfiguration.TopicCreation	forKafkaTopicAutoCreation()
Integer	getConcurrency()
List<DestinationTopic.Properties>	getDestinationTopicProperties()
EndpointHandlerMethod	getDltHandlerMethod()
boolean	hasConfigurationForTopics(String[] topics)

Methods inherited from class java.lang.Object

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

Method Details

hasConfigurationForTopics

public boolean hasConfigurationForTopics(String[] topics)

forKafkaTopicAutoCreation

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

forContainerFactoryResolver

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

getDltHandlerMethod

public EndpointHandlerMethod getDltHandlerMethod()

getDestinationTopicProperties

public List<DestinationTopic.Properties> getDestinationTopicProperties()

getConcurrency

@Nullable
public Integer getConcurrency()