Package | Description |
---|---|
org.axonframework.kafka.eventhandling.producer |
Modifier and Type | Method and Description |
---|---|
static <K,V> DefaultProducerFactory.Builder<K,V> |
DefaultProducerFactory.builder(Map<String,Object> configs) |
DefaultProducerFactory.Builder<K,V> |
DefaultProducerFactory.Builder.withCloseTimeout(int timeout,
TimeUnit unit)
How long to wait when
Producer.close(long, TimeUnit) is invoked. |
DefaultProducerFactory.Builder<K,V> |
DefaultProducerFactory.Builder.withConfirmationMode(ConfirmationMode confirmationMode)
Mode for producing
Producer . |
DefaultProducerFactory.Builder<K,V> |
DefaultProducerFactory.Builder.withProducerCacheSize(int producerCacheSize)
How many producer instances to cache.
|
DefaultProducerFactory.Builder<K,V> |
DefaultProducerFactory.Builder.withTransactionalIdPrefix(String transactionIdPrefix)
Transactional id prefix.
|
Copyright © 2010–2018. All rights reserved.