Uses of Interface
org.springframework.kafka.config.KafkaListenerEndpoint
Package
Description
Package for kafka configuration
Package for retryable topic handling.
-
Uses of KafkaListenerEndpoint in org.springframework.kafka.config
Modifier and TypeClassDescriptionclass
Base model for a Kafka listener endpoint.class
AKafkaListenerEndpoint
providing the method to invoke to process an incoming message for this endpoint.class
TheMethodKafkaListenerEndpoint
extension for several POJO methods based on theKafkaHandler
.Modifier and TypeMethodDescriptionprotected 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) AbstractKafkaListenerContainerFactory.createListenerContainer
(KafkaListenerEndpoint endpoint) KafkaListenerContainerFactory.createListenerContainer
(KafkaListenerEndpoint endpoint) Create aMessageListenerContainer
for the givenKafkaListenerEndpoint
.protected MessageListenerContainer
KafkaListenerEndpointRegistry.createListenerContainer
(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory) Create and start a newMessageListenerContainer
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 newKafkaListenerEndpoint
using the defaultKafkaListenerContainerFactory
to create the underlying container.void
KafkaListenerEndpointRegistrar.registerEndpoint
(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory) Register a newKafkaListenerEndpoint
alongside theKafkaListenerContainerFactory
to use to create the underlying container.void
KafkaListenerEndpointRegistry.registerListenerContainer
(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory) Create a message listener container for the givenKafkaListenerEndpoint
.void
KafkaListenerEndpointRegistry.registerListenerContainer
(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory, boolean startImmediately) Create a message listener container for the givenKafkaListenerEndpoint
. -
Uses of KafkaListenerEndpoint in org.springframework.kafka.retrytopic
Modifier and TypeMethodDescriptionRetryTopicNamesProviderFactory.RetryTopicNamesProvider.getClientIdPrefix
(KafkaListenerEndpoint endpoint) Return the clientId prefix that will override the endpoint's clientId prefix.SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider.getClientIdPrefix
(KafkaListenerEndpoint endpoint) RetryTopicNamesProviderFactory.RetryTopicNamesProvider.getEndpointId
(KafkaListenerEndpoint endpoint) Return the endpoint id that will override the endpoint's current id.SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider.getEndpointId
(KafkaListenerEndpoint endpoint) RetryTopicNamesProviderFactory.RetryTopicNamesProvider.getGroup
(KafkaListenerEndpoint endpoint) Return the group that will override the endpoint's group.SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider.getGroup
(KafkaListenerEndpoint endpoint) RetryTopicNamesProviderFactory.RetryTopicNamesProvider.getGroupId
(KafkaListenerEndpoint endpoint) Return the groupId that will override the endpoint's groupId.SuffixingRetryTopicNamesProviderFactory.SuffixingRetryTopicNamesProvider.getGroupId
(KafkaListenerEndpoint endpoint)