Package org.springframework.kafka.retrytopic

Class SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider

java.lang.Object

org.springframework.kafka.retrytopic.SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider

All Implemented Interfaces:

RetryTopicNamesProviderFactory.RetryTopicNamesProvider

Enclosing class:

SuffixingRetryTopicNamesProviderFactory

public static class SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider
extends Object
implements RetryTopicNamesProviderFactory.RetryTopicNamesProvider

Constructor Summary

Constructors

Constructor	Description
SuffixingRetryTopicNamesProvider(DestinationTopic.Properties properties)

Method Summary

Modifier and Type	Method	Description
String	getClientIdPrefix(MethodKafkaListenerEndpoint<?,?> endpoint)	Return the clientId prefix that will override the endpoint's clientId prefix.
String	getEndpointId(MethodKafkaListenerEndpoint<?,?> endpoint)	Return the endpoint id that will override the endpoint's current id.
String	getGroup(MethodKafkaListenerEndpoint<?,?> endpoint)	Return the group that will override the endpoint's group.
String	getGroupId(MethodKafkaListenerEndpoint<?,?> endpoint)	Return the groupId that will override the endpoint's groupId.
String	getTopicName(String topic)	Return the tropic name that will override the base topic name.

Methods inherited from class java.lang.Object

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

Constructor Details

SuffixingRetryTopicNamesProvider

public SuffixingRetryTopicNamesProvider(DestinationTopic.Properties properties)

Method Details

getEndpointId

public String getEndpointId(MethodKafkaListenerEndpoint<?,?> endpoint)

Description copied from interface: RetryTopicNamesProviderFactory.RetryTopicNamesProvider

Return the endpoint id that will override the endpoint's current id.

Specified by:

getEndpointId in interface RetryTopicNamesProviderFactory.RetryTopicNamesProvider

Parameters:

endpoint - the endpoint to override

Returns:

The endpoint id

getGroupId

public String getGroupId(MethodKafkaListenerEndpoint<?,?> endpoint)

Description copied from interface: RetryTopicNamesProviderFactory.RetryTopicNamesProvider

Return the groupId that will override the endpoint's groupId.

Specified by:

getGroupId in interface RetryTopicNamesProviderFactory.RetryTopicNamesProvider

Parameters:

endpoint - the endpoint to override

Returns:

The groupId

getClientIdPrefix

public String getClientIdPrefix(MethodKafkaListenerEndpoint<?,?> endpoint)

Description copied from interface: RetryTopicNamesProviderFactory.RetryTopicNamesProvider

Return the clientId prefix that will override the endpoint's clientId prefix.

Specified by:

getClientIdPrefix in interface RetryTopicNamesProviderFactory.RetryTopicNamesProvider

Parameters:

endpoint - the endpoint to override

Returns:

The clientId prefix

getGroup

public String getGroup(MethodKafkaListenerEndpoint<?,?> endpoint)

Description copied from interface: RetryTopicNamesProviderFactory.RetryTopicNamesProvider

Return the group that will override the endpoint's group.

Specified by:

getGroup in interface RetryTopicNamesProviderFactory.RetryTopicNamesProvider

Parameters:

endpoint - the endpoint to override

Returns:

The clientId prefix

getTopicName

public String getTopicName(String topic)

Description copied from interface: RetryTopicNamesProviderFactory.RetryTopicNamesProvider

Return the tropic name that will override the base topic name.

Specified by:

getTopicName in interface RetryTopicNamesProviderFactory.RetryTopicNamesProvider

Parameters:

topic - the base topic name

Returns:

The topic name