Package org.springframework.kafka.retrytopic

Interface RetryTopicNamesProviderFactory.RetryTopicNamesProvider

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

  • Method Details

    • getEndpointId

      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

      String getGroupId(MethodKafkaListenerEndpoint<?,?> endpoint)
      Return the groupId that will override the endpoint's groupId.
      Parameters:
      endpoint - the endpoint to override
      Returns:
      The groupId

    • getClientIdPrefix

      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

      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

      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