Package org.springframework.kafka.retrytopic

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:

• EndpointCustomizerFactory

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static class	EndpointCustomizer.TopicNamesHolder

Method Summary

Modifier and Type	Method	Description
Collection<EndpointCustomizer.TopicNamesHolder>	customizeEndpointAndCollectTopics(T listenerEndpoint)	Customize the endpoint and return the topic names generated for this endpoint.

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.