org.axonframework.kafka.eventhandling.producer

Class KafkaPublisherConfiguration.Builder<K,V>

java.lang.Object

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

Enclosing class:

KafkaPublisherConfiguration<K,V>

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

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
KafkaPublisherConfiguration<K,V>	build()
KafkaPublisherConfiguration.Builder<K,V>	withMessageConverter(KafkaMessageConverter<K,V> messageConverter) Configure KafkaMessageConverter.
KafkaPublisherConfiguration.Builder<K,V>	withMessageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor) Configure MessageMonitor.
KafkaPublisherConfiguration.Builder<K,V>	withMessageSource(SubscribableMessageSource<EventMessage<?>> messageSource) Configure SubscribableMessageSource.
KafkaPublisherConfiguration.Builder<K,V>	withProducerFactory(ProducerFactory<K,V> producerFactory) Configure ProducerFactory.
KafkaPublisherConfiguration.Builder<K,V>	withPublisherAckTimeout(long timeoutInMillis)
KafkaPublisherConfiguration.Builder<K,V>	withTopic(String topic) Configure Kafka topic for publishing messages, default to Axon.EventBus.

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

withMessageSource

public KafkaPublisherConfiguration.Builder<K,V> withMessageSource(SubscribableMessageSource<EventMessage<?>> messageSource)

Configure SubscribableMessageSource.

Parameters:

messageSource - the message source.

Returns:

the builder.

withProducerFactory

public KafkaPublisherConfiguration.Builder<K,V> withProducerFactory(ProducerFactory<K,V> producerFactory)

Configure ProducerFactory.

Parameters:

producerFactory - the producer factory.

Returns:

the builder.

withMessageConverter

public KafkaPublisherConfiguration.Builder<K,V> withMessageConverter(KafkaMessageConverter<K,V> messageConverter)

Configure KafkaMessageConverter.

Parameters:

messageConverter - the message converter.

Returns:

the builder.

withMessageMonitor

public KafkaPublisherConfiguration.Builder<K,V> withMessageMonitor(MessageMonitor<? super EventMessage<?>> messageMonitor)

Configure MessageMonitor.

Parameters:

messageMonitor - the message monitor.

Returns:

the builder.

withTopic

public KafkaPublisherConfiguration.Builder<K,V> withTopic(String topic)

Configure Kafka topic for publishing messages, default to Axon.EventBus.

Parameters:

topic - the topic.

Returns:

the builder.

withPublisherAckTimeout

public KafkaPublisherConfiguration.Builder<K,V> withPublisherAckTimeout(long timeoutInMillis)

Parameters:

timeoutInMillis - how long to wait for publisher to acknowledge send, expressed in millis. Default to 1 sec.

Returns:

the builder.

build

public KafkaPublisherConfiguration<K,V> build()