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