org.axonframework.kafka.eventhandling.producer

Class KafkaPublisher<K,V>

java.lang.Object

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

Type Parameters:

K - the key type.

V - the value type.

public class KafkaPublisher<K,V>
extends Object

Publisher implementation that uses Kafka Message Broker to dispatch event messages. All outgoing messages are sent to a configured topics.

This terminal does not dispatch Events internally, as it relies on each event processor to listen to it's own Kafka Topic.

Since:

3.0

Author:

Nakul Mishra

Constructor Summary

Constructors

Constructor and Description
KafkaPublisher(KafkaPublisherConfiguration<K,V> config) Initialize this instance to publish message as they are published on the given messageSource.

Method Summary

Modifier and Type	Method and Description
protected void	send(List<? extends EventMessage<?>> events) Send events to the configured Kafka topic.
void	shutDown() Shuts down this component and unsubscribes it from its messageSource.
void	start() Subscribes this publisher to the messageSource provided during initialization.

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaPublisher

public KafkaPublisher(KafkaPublisherConfiguration<K,V> config)

Initialize this instance to publish message as they are published on the given messageSource.

Parameters:

config - Publisher configuration used for initialization

Method Detail

start

public void start()

Subscribes this publisher to the messageSource provided during initialization.

shutDown

public void shutDown()

Shuts down this component and unsubscribes it from its messageSource.

send

protected void send(List<? extends EventMessage<?>> events)

Send events to the configured Kafka topic. It takes the current Unit of Work into account when available.

If ProducerFactory is configured to use:

• Transactions: use kafka transactions for publishing events
• Ack: send messages and wait for acknowledgement from Kafka. Acknowledgement timeout can be configured via KafkaPublisherConfiguration.Builder.withPublisherAckTimeout(long)).
• None: fire and forget.

Parameters:

events - the events to publish on the Kafka broker.