Interface RetryTopicNamesProviderFactory.RetryTopicNamesProvider

All Known Implementing Classes:

SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider

Enclosing interface:

RetryTopicNamesProviderFactory

public static interface RetryTopicNamesProviderFactory.RetryTopicNamesProvider

Author:

Andrea Polci

Method Summary

Modifier and Type	Method	Description
String	getClientIdPrefix(KafkaListenerEndpoint endpoint)	Return the clientId prefix that will override the endpoint's clientId prefix.
String	getEndpointId(KafkaListenerEndpoint endpoint)	Return the endpoint id that will override the endpoint's current id.
String	getGroup(KafkaListenerEndpoint endpoint)	Return the group that will override the endpoint's group.
String	getGroupId(KafkaListenerEndpoint endpoint)	Return the groupId that will override the endpoint's groupId.
String	getTopicName(String topic)	Return the tropic name that will override the base topic name.

Method Details

getEndpointId

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

String getGroupId(KafkaListenerEndpoint endpoint)

Return the groupId that will override the endpoint's groupId.

Parameters:

endpoint - the endpoint to override

Returns:

The groupId

getClientIdPrefix

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

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

String getTopicName(String topic)

Return the tropic name that will override the base topic name.

Parameters:

topic - the base topic name

Returns:

The topic name