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 -
Method Summary
Modifier and TypeMethodDescription@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.
-
Constructor Details
-
SuffixingRetryTopicNamesProvider
-
-
Method Details
-
getEndpointId
Description copied from interface:RetryTopicNamesProviderFactory.RetryTopicNamesProvider
Return the endpoint id that will override the endpoint's current id.- Specified by:
getEndpointId
in interfaceRetryTopicNamesProviderFactory.RetryTopicNamesProvider
- Parameters:
endpoint
- the endpoint to override- Returns:
- The endpoint id
-
getGroupId
Description copied from interface:RetryTopicNamesProviderFactory.RetryTopicNamesProvider
Return the groupId that will override the endpoint's groupId.- Specified by:
getGroupId
in interfaceRetryTopicNamesProviderFactory.RetryTopicNamesProvider
- Parameters:
endpoint
- the endpoint to override- Returns:
- The groupId
-
getClientIdPrefix
Description copied from interface:RetryTopicNamesProviderFactory.RetryTopicNamesProvider
Return the clientId prefix that will override the endpoint's clientId prefix.- Specified by:
getClientIdPrefix
in interfaceRetryTopicNamesProviderFactory.RetryTopicNamesProvider
- Parameters:
endpoint
- the endpoint to override- Returns:
- The clientId prefix
-
getGroup
Description copied from interface:RetryTopicNamesProviderFactory.RetryTopicNamesProvider
Return the group that will override the endpoint's group.- Specified by:
getGroup
in interfaceRetryTopicNamesProviderFactory.RetryTopicNamesProvider
- Parameters:
endpoint
- the endpoint to override- Returns:
- The clientId prefix
-
getTopicName
Description copied from interface:RetryTopicNamesProviderFactory.RetryTopicNamesProvider
Return the tropic name that will override the base topic name.- Specified by:
getTopicName
in interfaceRetryTopicNamesProviderFactory.RetryTopicNamesProvider
- Parameters:
topic
- the base topic name- Returns:
- The topic name
-