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 TypeMethodDescriptionvoidAbstractKafkaListenerContainerFactory.setConsumerFactory(ConsumerFactory<? super K, ? super V> consumerFactory) Specify aConsumerFactoryto use. -
Uses of ConsumerFactory in org.springframework.kafka.core
Classes in org.springframework.kafka.core that implement ConsumerFactoryModifier and TypeClassDescriptionclassTheConsumerFactoryimplementation to produce newConsumerinstances for providedMapconfigsand optionalDeserializers on eachcreateConsumer()invocation.Methods in org.springframework.kafka.core with parameters of type ConsumerFactoryModifier and TypeMethodDescriptionvoidKafkaTemplate.setConsumerFactory(ConsumerFactory<K, V> consumerFactory) Set a consumer factory for receive operations. -
Uses of ConsumerFactory in org.springframework.kafka.jdocs.started.noboot
Methods in org.springframework.kafka.jdocs.started.noboot that return ConsumerFactory -
Uses of ConsumerFactory in org.springframework.kafka.listener
Fields in org.springframework.kafka.listener declared as ConsumerFactoryModifier and TypeFieldDescriptionprotected final ConsumerFactory<K,V> AbstractMessageListenerContainer.consumerFactoryMethods 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 ConsumerFactoryModifierConstructorDescriptionprotectedAbstractMessageListenerContainer(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 TypeClassDescriptionclassMockConsumerFactory<K,V> Support the use ofMockConsumerin tests.