org.axonframework.kafka.eventhandling.producer

Class KafkaPublisherConfiguration<K,V>

java.lang.Object

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

Type Parameters:

K - the key type.

V - the value type.

public class KafkaPublisherConfiguration<K,V>
extends Object

Configures KafkaPublisher.

Since:

3.0

Author:

Nakul Mishra

Nested Class Summary

Nested Classes

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

Method Summary

Modifier and Type	Method and Description
static <K,V> KafkaPublisherConfiguration.Builder<K,V>	builder()
KafkaMessageConverter<K,V>	getMessageConverter()
MessageMonitor<? super EventMessage<?>>	getMessageMonitor()
SubscribableMessageSource<EventMessage<?>>	getMessageSource()
ProducerFactory<K,V>	getProducerFactory()
long	getPublisherAckTimeout()
String	getTopic()

Methods inherited from class java.lang.Object

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

Method Detail

getMessageSource

public SubscribableMessageSource<EventMessage<?>> getMessageSource()

getProducerFactory

public ProducerFactory<K,V> getProducerFactory()

getMessageConverter

public KafkaMessageConverter<K,V> getMessageConverter()

getMessageMonitor

public MessageMonitor<? super EventMessage<?>> getMessageMonitor()

getTopic

public String getTopic()

getPublisherAckTimeout

public long getPublisherAckTimeout()

builder

public static <K,V> KafkaPublisherConfiguration.Builder<K,V> builder()