Uses of Interface
org.springframework.kafka.core.ProducerFactory

Packages that use ProducerFactory

Package	Description
org.springframework.kafka.core	Package for kafka core components
org.springframework.kafka.mock	Provides classes to support the use of MockConsumer and MockProducer.
org.springframework.kafka.requestreply	Provides classes for request/reply semantics.
org.springframework.kafka.transaction	Provides classes related to transactions.

Uses of ProducerFactory in org.springframework.kafka.core

Classes in org.springframework.kafka.core that implement ProducerFactory

Modifier and Type	Class	Description
class	DefaultKafkaProducerFactory<K,V>	The ProducerFactory implementation for a singleton shared Producer instance.

Methods in org.springframework.kafka.core that return ProducerFactory

Modifier and Type	Method	Description
ProducerFactory<K,V>	DefaultKafkaProducerFactory.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.
ProducerFactory<K,V>	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.
ProducerFactory<Object,Object>	RoutingKafkaTemplate.getProducerFactory()
ProducerFactory<Object,Object>	RoutingKafkaTemplate.getProducerFactory(String topic)

Methods in org.springframework.kafka.core with parameters of type ProducerFactory

Modifier and Type	Method	Description
static <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 ProducerFactory

Modifier	Constructor	Description
	KafkaTemplate(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 ProducerFactory

Modifier	Constructor	Description
	RoutingKafkaTemplate(Map<Pattern,ProducerFactory<Object,Object>> factories)	Construct an instance with the provided properties.

Uses of ProducerFactory in org.springframework.kafka.mock

Classes in org.springframework.kafka.mock that implement ProducerFactory

Modifier and Type	Class	Description
class	MockProducerFactory<K,V>	Support the use of MockProducer in tests.

Uses of ProducerFactory in org.springframework.kafka.requestreply

Constructors in org.springframework.kafka.requestreply with parameters of type ProducerFactory

Modifier	Constructor	Description
	AggregatingReplyingKafkaTemplate(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 ProducerFactory

Modifier and Type	Method	Description
ProducerFactory<K,V>	ChainedKafkaTransactionManager.getProducerFactory()	Deprecated.
ProducerFactory<K,V>	KafkaAwareTransactionManager.getProducerFactory()	Get the producer factory.
ProducerFactory<K,V>	KafkaTransactionManager.getProducerFactory()	Get the producer factory.

Constructors in org.springframework.kafka.transaction with parameters of type ProducerFactory

Modifier	Constructor	Description
	KafkaTransactionManager(ProducerFactory<K,V> producerFactory)	Create a new KafkaTransactionManager, given a ProducerFactory.