Uses of Interface
org.springframework.kafka.config.KafkaListenerEndpoint
Packages that use KafkaListenerEndpoint
Package
Description
Package for kafka configuration
Package for retryable topic handling.
-
Uses of KafkaListenerEndpoint in org.springframework.kafka.config
Classes in org.springframework.kafka.config that implement KafkaListenerEndpointModifier and TypeClassDescriptionclassBase model for a Kafka listener endpoint.classAKafkaListenerEndpointproviding the method to invoke to process an incoming message for this endpoint.classTheMethodKafkaListenerEndpointextension for several POJO methods based on theKafkaHandler.Methods in org.springframework.kafka.config with parameters of type KafkaListenerEndpointModifier and TypeMethodDescriptionprotected abstract CAbstractKafkaListenerContainerFactory.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 aMessageListenerContainerfor the givenKafkaListenerEndpoint.protected MessageListenerContainerKafkaListenerEndpointRegistry.createListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory) Create and start a newMessageListenerContainerusing the specified factory.protected voidAbstractKafkaListenerContainerFactory.initializeContainer(C instance, KafkaListenerEndpoint endpoint) Further initialize the specified container.protected voidConcurrentKafkaListenerContainerFactory.initializeContainer(ConcurrentMessageListenerContainer<K, V> instance, KafkaListenerEndpoint endpoint) voidKafkaListenerEndpointRegistrar.registerEndpoint(KafkaListenerEndpoint endpoint) Register a newKafkaListenerEndpointusing the defaultKafkaListenerContainerFactoryto create the underlying container.voidKafkaListenerEndpointRegistrar.registerEndpoint(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory) Register a newKafkaListenerEndpointalongside theKafkaListenerContainerFactoryto use to create the underlying container.voidKafkaListenerEndpointRegistry.registerListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory) Create a message listener container for the givenKafkaListenerEndpoint.voidKafkaListenerEndpointRegistry.registerListenerContainer(KafkaListenerEndpoint endpoint, KafkaListenerContainerFactory<?> factory, boolean startImmediately) Create a message listener container for the givenKafkaListenerEndpoint. -
Uses of KafkaListenerEndpoint in org.springframework.kafka.retrytopic
Methods in org.springframework.kafka.retrytopic with parameters of type KafkaListenerEndpointModifier 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)