Interface RetryTopicNamesProviderFactory.RetryTopicNamesProvider
-
- All Known Implementing Classes:
SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider
- Enclosing interface:
- RetryTopicNamesProviderFactory
public static interface RetryTopicNamesProviderFactory.RetryTopicNamesProvider
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description java.lang.String
getClientIdPrefix(KafkaListenerEndpoint endpoint)
Return the clientId prefix that will override the endpoint's clientId prefix.java.lang.String
getEndpointId(KafkaListenerEndpoint endpoint)
Return the endpoint id that will override the endpoint's current id.java.lang.String
getGroup(KafkaListenerEndpoint endpoint)
Return the group that will override the endpoint's group.java.lang.String
getGroupId(KafkaListenerEndpoint endpoint)
Return the groupId that will override the endpoint's groupId.java.lang.String
getTopicName(java.lang.String topic)
Return the tropic name that will override the base topic name.
-
-
-
Method Detail
-
getEndpointId
java.lang.String getEndpointId(KafkaListenerEndpoint endpoint)
Return the endpoint id that will override the endpoint's current id.- Parameters:
endpoint
- the endpoint to override- Returns:
- The endpoint id
-
getGroupId
java.lang.String getGroupId(KafkaListenerEndpoint endpoint)
Return the groupId that will override the endpoint's groupId.- Parameters:
endpoint
- the endpoint to override- Returns:
- The groupId
-
getClientIdPrefix
java.lang.String getClientIdPrefix(KafkaListenerEndpoint endpoint)
Return the clientId prefix that will override the endpoint's clientId prefix.- Parameters:
endpoint
- the endpoint to override- Returns:
- The clientId prefix
-
getGroup
java.lang.String getGroup(KafkaListenerEndpoint endpoint)
Return the group that will override the endpoint's group.- Parameters:
endpoint
- the endpoint to override- Returns:
- The clientId prefix
-
getTopicName
java.lang.String getTopicName(java.lang.String topic)
Return the tropic name that will override the base topic name.- Parameters:
topic
- the base topic name- Returns:
- The topic name
-
-