Uses of Interface
org.springframework.kafka.core.ProducerFactory
Packages that use ProducerFactory
Package
Description
Package for kafka core components
Provides classes for request/reply semantics.
Provides classes related to transactions.
-
Uses of ProducerFactory in org.springframework.kafka.core
Classes in org.springframework.kafka.core that implement ProducerFactoryModifier and TypeClassDescriptionclassMethods in org.springframework.kafka.core that return ProducerFactoryModifier and TypeMethodDescriptionDefaultKafkaProducerFactory.copyWithConfigurationOverride(Map<String, Object> overrideProperties) Copy properties of the instance and the given properties to create a new producer factory.default ProducerFactory<K,V> ProducerFactory.copyWithConfigurationOverride(Map<String, Object> overrideProperties) Copy the properties of the instance and the given properties to create a new producer factory.default ProducerFactory<K,V> KafkaOperations.getProducerFactory()Return the producer factory used by this template.default ProducerFactory<K,V> KafkaOperations2.getProducerFactory()Deprecated, for removal: This API element is subject to removal in a future version.Return the producer factory used by this template.KafkaTemplate.getProducerFactory()Return the producer factory used by this template.protected ProducerFactory<K,V> KafkaTemplate.getProducerFactory(String topic) Return the producer factory used by this template based on the topic.RoutingKafkaTemplate.getProducerFactory()RoutingKafkaTemplate.getProducerFactory(String topic) Methods in org.springframework.kafka.core with parameters of type ProducerFactoryModifier and TypeMethodDescriptionstatic <K,V> KafkaResourceHolder<K, V> ProducerFactoryUtils.getTransactionalResourceHolder(ProducerFactory<K, V> producerFactory) Obtain a Producer that is synchronized with the current transaction, if any.static <K,V> KafkaResourceHolder<K, V> ProducerFactoryUtils.getTransactionalResourceHolder(ProducerFactory<K, V> producerFactory, String txIdPrefix, Duration closeTimeout) Obtain a Producer that is synchronized with the current transaction, if any.static <K,V> KafkaResourceHolder<K, V> ProducerFactoryUtils.getTransactionalResourceHolder(ProducerFactory<K, V> producerFactory, Duration closeTimeout) Obtain a Producer that is synchronized with the current transaction, if any.Constructors in org.springframework.kafka.core with parameters of type ProducerFactoryModifierConstructorDescriptionKafkaTemplate(ProducerFactory<K, V> producerFactory) Create an instance using the supplied producer factory and autoFlush false.KafkaTemplate(ProducerFactory<K, V> producerFactory, boolean autoFlush) Create an instance using the supplied producer factory and autoFlush setting.KafkaTemplate(ProducerFactory<K, V> producerFactory, boolean autoFlush, Map<String, Object> configOverrides) Create an instance using the supplied producer factory and autoFlush setting.KafkaTemplate(ProducerFactory<K, V> producerFactory, Map<String, Object> configOverrides) Create an instance using the supplied producer factory and properties, with autoFlush false.Constructor parameters in org.springframework.kafka.core with type arguments of type ProducerFactoryModifierConstructorDescriptionRoutingKafkaTemplate(Map<Pattern, ProducerFactory<Object, Object>> factories) Construct an instance with the provided properties. -
Uses of ProducerFactory in org.springframework.kafka.jdocs.started.noboot
Methods in org.springframework.kafka.jdocs.started.noboot that return ProducerFactoryMethods in org.springframework.kafka.jdocs.started.noboot with parameters of type ProducerFactoryModifier and TypeMethodDescriptionConfig.kafkaTemplate(ProducerFactory<Integer, String> producerFactory) -
Uses of ProducerFactory in org.springframework.kafka.requestreply
Constructors in org.springframework.kafka.requestreply with parameters of type ProducerFactoryModifierConstructorDescriptionAggregatingReplyingKafkaTemplate(ProducerFactory<K, V> producerFactory, GenericMessageListenerContainer<K, Collection<org.apache.kafka.clients.consumer.ConsumerRecord<K, R>>> replyContainer, BiPredicate<List<org.apache.kafka.clients.consumer.ConsumerRecord<K, R>>, Boolean> releaseStrategy) Construct an instance using the provided parameter arguments.ReplyingKafkaTemplate(ProducerFactory<K, V> producerFactory, GenericMessageListenerContainer<K, R> replyContainer) ReplyingKafkaTemplate(ProducerFactory<K, V> producerFactory, GenericMessageListenerContainer<K, R> replyContainer, boolean autoFlush) -
Uses of ProducerFactory in org.springframework.kafka.transaction
Methods in org.springframework.kafka.transaction that return ProducerFactoryModifier and TypeMethodDescriptionChainedKafkaTransactionManager.getProducerFactory()Deprecated.KafkaAwareTransactionManager.getProducerFactory()Get the producer factory.KafkaTransactionManager.getProducerFactory()Get the producer factory.Constructors in org.springframework.kafka.transaction with parameters of type ProducerFactoryModifierConstructorDescriptionKafkaTransactionManager(ProducerFactory<K, V> producerFactory) Create a new KafkaTransactionManager, given a ProducerFactory.