Uses of Interface
org.springframework.kafka.core.ConsumerFactory
Package
Description
Package for kafka configuration
Package for kafka core components
Package for kafka listeners
Provides classes to support the use of MockConsumer and MockProducer.
-
Uses of ConsumerFactory in org.springframework.kafka.config
Modifier and TypeMethodDescriptionConsumerFactory<? super K,
? super V> AbstractKafkaListenerContainerFactory.getConsumerFactory()
Modifier and TypeMethodDescriptionvoid
AbstractKafkaListenerContainerFactory.setConsumerFactory
(ConsumerFactory<? super K, ? super V> consumerFactory) Specify aConsumerFactory
to use. -
Uses of ConsumerFactory in org.springframework.kafka.core
Modifier and TypeClassDescriptionclass
TheConsumerFactory
implementation to produce newConsumer
instances for providedMap
configs
and optionalDeserializer
s on eachcreateConsumer()
invocation.Modifier and TypeMethodDescriptionvoid
KafkaTemplate.setConsumerFactory
(ConsumerFactory<K, V> consumerFactory) Set a consumer factory for receive operations. -
Uses of ConsumerFactory in org.springframework.kafka.listener
Modifier and TypeFieldDescriptionprotected final ConsumerFactory<K,
V> AbstractMessageListenerContainer.consumerFactory
Modifier and TypeMethodDescriptionstatic <K,
V> boolean ErrorHandlingUtils.checkDeserializer
(ConsumerFactory<K, V> consumerFactory, Properties consumerOverrides, boolean isValue, ClassLoader classLoader) Determine whether the key or value deserializer is an instance ofErrorHandlingDeserializer
.ModifierConstructorDescriptionprotected
AbstractMessageListenerContainer
(ConsumerFactory<? super K, ? super V> consumerFactory, ContainerProperties containerProperties) Construct an instance with the provided factory and properties.ConcurrentMessageListenerContainer
(ConsumerFactory<? super K, ? super V> consumerFactory, ContainerProperties containerProperties) Construct an instance with the supplied configuration properties.KafkaMessageListenerContainer
(ConsumerFactory<? super K, ? super V> consumerFactory, ContainerProperties containerProperties) Construct an instance with the supplied configuration properties. -
Uses of ConsumerFactory in org.springframework.kafka.mock
Modifier and TypeClassDescriptionclass
MockConsumerFactory<K,
V> Support the use ofMockConsumer
in tests.