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

Author:

Andrea Polci

Constructor Summary

Constructors

Constructor	Description
SuffixingRetryTopicNamesProvider(DestinationTopic.Properties properties)

Method Summary

Modifier and Type	Method	Description
@Nullable String	getClientIdPrefix(KafkaListenerEndpoint endpoint)	Return the clientId prefix that will override the endpoint's clientId prefix.
@Nullable String	getEndpointId(KafkaListenerEndpoint endpoint)	Return the endpoint id that will override the endpoint's current id.
@Nullable String	getGroup(KafkaListenerEndpoint endpoint)	Return the group that will override the endpoint's group.
@Nullable String	getGroupId(KafkaListenerEndpoint endpoint)	Return the groupId that will override the endpoint's groupId.
@Nullable 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 @Nullable String getEndpointId(KafkaListenerEndpoint 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 @Nullable String getGroupId(KafkaListenerEndpoint 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 @Nullable String getClientIdPrefix(KafkaListenerEndpoint 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 @Nullable String getGroup(KafkaListenerEndpoint 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 @Nullable 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