org.axonframework.kafka.eventhandling.producer

Class DefaultProducerFactory<K,V>

java.lang.Object

org.axonframework.kafka.eventhandling.producer.DefaultProducerFactory<K,V>

All Implemented Interfaces:

ProducerFactory<K,V>

public class DefaultProducerFactory<K,V>
extends Object
implements ProducerFactory<K,V>

The ProducerFactory implementation to produce a singleton shared Producer instance.

The Producer instance is freed from the external Producer.close() invocation with the internal wrapper. The real Producer.close() is called on the target Producer during the shutDown().

Setting DefaultProducerFactory.Builder.withConfirmationMode(ConfirmationMode) to transactional produces a transactional producer; in which case, a cache of producers is maintained; closing the producer returns it to the cache. If cache is full the producer will be closed KafkaProducer.close(long, TimeUnit) and evicted from cache.

Since:

3.0

Author:

Nakul Mishra

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DefaultProducerFactory.Builder<K,V>

Method Summary

Modifier and Type	Method and Description
static <K,V> DefaultProducerFactory.Builder<K,V>	builder(Map<String,Object> configs)
ConfirmationMode	confirmationMode() Confirmation mode for all producer instances.
org.apache.kafka.clients.producer.Producer<K,V>	createProducer() Create a producer with the settings supplied in configuration properties.
void	shutDown() Closes all producer instances.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

createProducer

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

Create a producer with the settings supplied in configuration properties.

Specified by:

createProducer in interface ProducerFactory<K,V>

Returns:

the producer.

confirmationMode

public ConfirmationMode confirmationMode()

Confirmation mode for all producer instances.

Specified by:

confirmationMode in interface ProducerFactory<K,V>

Returns:

the confirmation mode.

shutDown

public void shutDown()

Closes all producer instances.

Specified by:

shutDown in interface ProducerFactory<K,V>

builder

public static <K,V> DefaultProducerFactory.Builder<K,V> builder(Map<String,Object> configs)

Type Parameters:

K - key type.

V - value type.

Parameters:

configs - Kafka properties for creating a producer(s).

Returns:

the builder.