org.axonframework.kafka.eventhandling.producer

Class DefaultProducerFactory.Builder<K,V>

java.lang.Object

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

Enclosing class:

DefaultProducerFactory<K,V>

public static final class DefaultProducerFactory.Builder<K,V>
extends Object

Method Summary

Modifier and Type	Method and Description
ProducerFactory<K,V>	build()
DefaultProducerFactory.Builder<K,V>	withCloseTimeout(int timeout, TimeUnit unit) How long to wait when Producer.close(long, TimeUnit) is invoked.
DefaultProducerFactory.Builder<K,V>	withConfirmationMode(ConfirmationMode confirmationMode) Mode for producing Producer.
DefaultProducerFactory.Builder<K,V>	withProducerCacheSize(int producerCacheSize) How many producer instances to cache.
DefaultProducerFactory.Builder<K,V>	withTransactionalIdPrefix(String transactionIdPrefix) Transactional id prefix.

Methods inherited from class java.lang.Object

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

Method Detail

withProducerCacheSize

public DefaultProducerFactory.Builder<K,V> withProducerCacheSize(int producerCacheSize)

How many producer instances to cache. Default to 10.

Parameters:

producerCacheSize - the cache size.

Returns:

the builder.

withCloseTimeout

public DefaultProducerFactory.Builder<K,V> withCloseTimeout(int timeout,
                                                            TimeUnit unit)

How long to wait when Producer.close(long, TimeUnit) is invoked. Default is 30 seconds.

Parameters:

timeout - how long to wait before closing a producer, in units of unit.

unit - a TimeUnit determining how to interpret the timeout parameter.

Returns:

the builder.

withConfirmationMode

public DefaultProducerFactory.Builder<K,V> withConfirmationMode(ConfirmationMode confirmationMode)

Mode for producing Producer.

Parameters:

confirmationMode, - default to ConfirmationMode.NONE.

Returns:

the builder.

withTransactionalIdPrefix

public DefaultProducerFactory.Builder<K,V> withTransactionalIdPrefix(String transactionIdPrefix)

Transactional id prefix.

Parameters:

transactionIdPrefix - prefix to generate transactional.id. Required for transactional producers.

Returns:

the builder.

build

public ProducerFactory<K,V> build()