Interface EndpointCustomizer<T extends MethodKafkaListenerEndpoint<?,?>>

Type Parameters:
T - the listener endpoint type.
Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface public interface EndpointCustomizer<T extends MethodKafkaListenerEndpoint<?,?>>
Customizes main, retry and DLT endpoints in the Retry Topic functionality and returns the resulting topic names.
Since:
2.7.2
Author:
Tomaz Fernandes, Wang Zhiyang
See Also:
  • Method Details

    • customizeEndpointAndCollectTopics

      Collection<EndpointCustomizer.TopicNamesHolder> customizeEndpointAndCollectTopics(T listenerEndpoint)
      Customize the endpoint and return the topic names generated for this endpoint.
      Parameters:
      listenerEndpoint - The main, retry or DLT endpoint to be customized.
      Returns:
      A collection containing the topic names generated for this endpoint.