Uses of Interface
org.springframework.kafka.config.KafkaListenerEndpoint

Packages that use KafkaListenerEndpoint

Package	Description
org.springframework.kafka.config	Package for kafka configuration
org.springframework.kafka.retrytopic	Package for retryable topic handling.

Uses of KafkaListenerEndpoint in org.springframework.kafka.config

Classes in org.springframework.kafka.config that implement KafkaListenerEndpoint

Modifier and Type	Class	Description
class	AbstractKafkaListenerEndpoint<K,V>	Base model for a Kafka listener endpoint.
class	MethodKafkaListenerEndpoint<K,V>	A KafkaListenerEndpoint providing the method to invoke to process an incoming message for this endpoint.
class	MultiMethodKafkaListenerEndpoint<K,V>	The MethodKafkaListenerEndpoint extension for several POJO methods based on the KafkaHandler.

Methods in org.springframework.kafka.config with parameters of type KafkaListenerEndpoint

Modifier and Type	Method	Description
protected C	AbstractKafkaListenerContainerFactory.createContainer(KafkaListenerEndpoint endpoint)
protected abstract C	AbstractKafkaListenerContainerFactory.createContainerInstance(KafkaListenerEndpoint endpoint)	Create an empty container instance.
protected ConcurrentMessageListenerContainer<K,V>	ConcurrentKafkaListenerContainerFactory.createContainerInstance(KafkaListenerEndpoint endpoint)
C	AbstractKafkaListenerContainerFactory.createListenerContainer(KafkaListenerEndpoint endpoint)
C	KafkaListenerContainerFactory.createListenerContainer(KafkaListenerEndpoint endpoint)	Create a MessageListenerContainer for the given KafkaListenerEndpoint.
protected MessageListenerContainer	KafkaListenerEndpointRegistry.createListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory)	Create and start a new MessageListenerContainer using the specified factory.
protected void	AbstractKafkaListenerContainerFactory.customizeContainer(C instance, KafkaListenerEndpoint endpoint)
protected void	AbstractKafkaListenerContainerFactory.initializeContainer(C instance, KafkaListenerEndpoint endpoint)	Further initialize the specified container.
protected void	ConcurrentKafkaListenerContainerFactory.initializeContainer(ConcurrentMessageListenerContainer<K,V> instance, KafkaListenerEndpoint endpoint)
void	KafkaListenerEndpointRegistrar.registerEndpoint(KafkaListenerEndpoint endpoint)	Register a new KafkaListenerEndpoint using the default KafkaListenerContainerFactory to create the underlying container.
void	KafkaListenerEndpointRegistrar.registerEndpoint(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory)	Register a new KafkaListenerEndpoint alongside the KafkaListenerContainerFactory to use to create the underlying container.
void	KafkaListenerEndpointRegistry.registerListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory)	Create a message listener container for the given KafkaListenerEndpoint.
void	KafkaListenerEndpointRegistry.registerListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory, boolean startImmediately)	Create a message listener container for the given KafkaListenerEndpoint.

Uses of KafkaListenerEndpoint in org.springframework.kafka.retrytopic

Methods in org.springframework.kafka.retrytopic with parameters of type KafkaListenerEndpoint

Modifier and Type	Method	Description
String	RetryTopicNamesProviderFactory.RetryTopicNamesProvider.getClientIdPrefix(KafkaListenerEndpoint endpoint)	Return the clientId prefix that will override the endpoint's clientId prefix.
String	SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider.getClientIdPrefix(KafkaListenerEndpoint endpoint)
String	RetryTopicNamesProviderFactory.RetryTopicNamesProvider.getEndpointId(KafkaListenerEndpoint endpoint)	Return the endpoint id that will override the endpoint's current id.
String	SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider.getEndpointId(KafkaListenerEndpoint endpoint)
String	RetryTopicNamesProviderFactory.RetryTopicNamesProvider.getGroup(KafkaListenerEndpoint endpoint)	Return the group that will override the endpoint's group.
String	SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider.getGroup(KafkaListenerEndpoint endpoint)
String	RetryTopicNamesProviderFactory.RetryTopicNamesProvider.getGroupId(KafkaListenerEndpoint endpoint)	Return the groupId that will override the endpoint's groupId.
String	SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider.getGroupId(KafkaListenerEndpoint endpoint)