Uses of Interface
org.springframework.kafka.core.ConsumerFactory
Packages that use 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
Methods in org.springframework.kafka.config that return ConsumerFactoryModifier and TypeMethodDescriptionConsumerFactory<? super K,
? super V> AbstractKafkaListenerContainerFactory.getConsumerFactory()
Methods in org.springframework.kafka.config with parameters of type ConsumerFactoryModifier and TypeMethodDescriptionvoid
AbstractKafkaListenerContainerFactory.setConsumerFactory
(ConsumerFactory<? super K, ? super V> consumerFactory) Specify aConsumerFactory
to use. -
Uses of ConsumerFactory in org.springframework.kafka.core
Classes in org.springframework.kafka.core that implement ConsumerFactoryModifier and TypeClassDescriptionclass
TheConsumerFactory
implementation to produce newConsumer
instances for providedMap
configs
and optionalDeserializer
s on eachcreateConsumer()
invocation.Methods in org.springframework.kafka.core with parameters of type ConsumerFactoryModifier and TypeMethodDescriptionvoid
KafkaTemplate.setConsumerFactory
(ConsumerFactory<K, V> consumerFactory) Set a consumer factory for receive operations. -
Uses of ConsumerFactory in org.springframework.kafka.listener
Fields in org.springframework.kafka.listener declared as ConsumerFactoryModifier and TypeFieldDescriptionprotected final ConsumerFactory<K,
V> AbstractMessageListenerContainer.consumerFactory
Methods in org.springframework.kafka.listener with parameters of type ConsumerFactoryModifier 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
.Constructors in org.springframework.kafka.listener with parameters of type ConsumerFactoryModifierConstructorDescriptionprotected
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
Classes in org.springframework.kafka.mock that implement ConsumerFactoryModifier and TypeClassDescriptionclass
MockConsumerFactory<K,
V> Support the use ofMockConsumer
in tests.