Interface RetryTopicNamesProviderFactory.RetryTopicNamesProvider
- All Known Implementing Classes:
SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider
- Enclosing interface:
- RetryTopicNamesProviderFactory
public static interface RetryTopicNamesProviderFactory.RetryTopicNamesProvider
-
Method Summary
Modifier and TypeMethodDescriptiongetClientIdPrefix
(MethodKafkaListenerEndpoint<?, ?> endpoint) Return the clientId prefix that will override the endpoint's clientId prefix.getEndpointId
(MethodKafkaListenerEndpoint<?, ?> endpoint) Return the endpoint id that will override the endpoint's current id.getGroup
(MethodKafkaListenerEndpoint<?, ?> endpoint) Return the group that will override the endpoint's group.getGroupId
(MethodKafkaListenerEndpoint<?, ?> 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.
-
Method Details
-
getEndpointId
Return the endpoint id that will override the endpoint's current id.- Parameters:
endpoint
- the endpoint to override- Returns:
- The endpoint id
-
getGroupId
Return the groupId that will override the endpoint's groupId.- Parameters:
endpoint
- the endpoint to override- Returns:
- The groupId
-
getClientIdPrefix
Return the clientId prefix that will override the endpoint's clientId prefix.- Parameters:
endpoint
- the endpoint to override- Returns:
- The clientId prefix
-
getGroup
Return the group that will override the endpoint's group.- Parameters:
endpoint
- the endpoint to override- Returns:
- The clientId prefix
-
getTopicName
Return the tropic name that will override the base topic name.- Parameters:
topic
- the base topic name- Returns:
- The topic name
-