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(MethodKafkaListenerEndpoint<?,?> endpoint)
Return the clientId prefix that will override the endpoint's clientId prefix.java.lang.String
getEndpointId(MethodKafkaListenerEndpoint<?,?> endpoint)
Return the endpoint id that will override the endpoint's current id.java.lang.String
getGroup(MethodKafkaListenerEndpoint<?,?> endpoint)
Return the group that will override the endpoint's group.java.lang.String
getGroupId(MethodKafkaListenerEndpoint<?,?> 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(MethodKafkaListenerEndpoint<?,?> 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(MethodKafkaListenerEndpoint<?,?> 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(MethodKafkaListenerEndpoint<?,?> 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(MethodKafkaListenerEndpoint<?,?> 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
-
-