org.springframework.kafka.core

Interface ProducerFactory<K,V>

Type Parameters:

K - the key type.

V - the value type.

All Known Implementing Classes:

DefaultKafkaProducerFactory

public interface ProducerFactory<K,V>

The strategy to produce a Producer instance(s).

Author:

Gary Russell

Method Summary

Modifier and Type	Method and Description
default void	closeProducerFor(java.lang.String transactionIdSuffix) Remove the specified producer from the cache and close it.
default void	closeThreadBoundProducer() If the factory implementation uses thread-bound producers, call this method to close and release this thread's producer.
org.apache.kafka.clients.producer.Producer<K,V>	createProducer() Create a producer.
default org.apache.kafka.clients.producer.Producer<K,V>	createProducer(java.lang.String txIdPrefix) Create a producer with an overridden transaction id prefix.
default boolean	isProducerPerConsumerPartition() Return the producerPerConsumerPartition.
default void	reset() Reset any state in the factory, if supported.
default boolean	transactionCapable() Return true if the factory supports transactions.

Method Detail

createProducer

org.apache.kafka.clients.producer.Producer<K,V> createProducer()

Create a producer.

Returns:

the producer.

createProducer

default org.apache.kafka.clients.producer.Producer<K,V> createProducer(java.lang.String txIdPrefix)

Create a producer with an overridden transaction id prefix.

Parameters:

txIdPrefix - the transaction id prefix.

Returns:

the producer.

Since:

2.3

transactionCapable

default boolean transactionCapable()

Return true if the factory supports transactions.

Returns:

true if transactional.

closeProducerFor

default void closeProducerFor(java.lang.String transactionIdSuffix)

Remove the specified producer from the cache and close it.

Parameters:

transactionIdSuffix - the producer's transaction id suffix.

Since:

1.3.8

isProducerPerConsumerPartition

default boolean isProducerPerConsumerPartition()

Return the producerPerConsumerPartition.

Returns:

the producerPerConsumerPartition.

Since:

1.3.8

closeThreadBoundProducer

default void closeThreadBoundProducer()

If the factory implementation uses thread-bound producers, call this method to close and release this thread's producer.

Since:

2.3

reset

default void reset()

Reset any state in the factory, if supported.

Since:

2.4