org.axonframework.kafka.eventhandling

Interface KafkaMessageConverter<K,V>

Type Parameters:

K - the key type.

V - the value type.

All Known Implementing Classes:

DefaultKafkaMessageConverter

public interface KafkaMessageConverter<K,V>

Converts Kafka Message from Axon Message and vice versa.

Since:

3.0

Author:

Nakul Mishra

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.clients.producer.ProducerRecord<K,V>	createKafkaMessage(EventMessage<?> eventMessage, String topic) Creates ProducerRecord for a given EventMessage
Optional<EventMessage<?>>	readKafkaMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord) Reconstruct an EventMessage from the given ConsumerRecord.

Method Detail

createKafkaMessage

org.apache.kafka.clients.producer.ProducerRecord<K,V> createKafkaMessage(EventMessage<?> eventMessage,
                                                                         String topic)

Creates ProducerRecord for a given EventMessage

Parameters:

eventMessage - the event message to send to Kafka.

topic - the Kafka topic.

Returns:

the record.

readKafkaMessage

Optional<EventMessage<?>> readKafkaMessage(org.apache.kafka.clients.consumer.ConsumerRecord<K,V> consumerRecord)

Reconstruct an EventMessage from the given ConsumerRecord. The returned optional resolves to a message if the given input parameters represented a correct EventMessage.

Parameters:

consumerRecord - Event message represented inside kafka

Returns:

The Event Message to publish on the local event processors