Interface RetryTopicNamesProviderFactory.RetryTopicNamesProvider

All Known Implementing Classes:
SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider
Enclosing interface:
RetryTopicNamesProviderFactory
public static interface RetryTopicNamesProviderFactory.RetryTopicNamesProvider
Author:
Andrea Polci

  • Method Details

    • getEndpointId

      @Nullable 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

      @Nullable String getGroupId(KafkaListenerEndpoint endpoint)
      Return the groupId that will override the endpoint's groupId.
      Parameters:
      endpoint - the endpoint to override
      Returns:
      The groupId

    • getClientIdPrefix

      @Nullable 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

      @Nullable 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

      @Nullable 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