org.axonframework.kafka.eventhandling.consumer

Class KafkaMessageSource

java.lang.Object

org.axonframework.kafka.eventhandling.consumer.KafkaMessageSource

All Implemented Interfaces:

StreamableMessageSource<TrackedEventMessage<?>>

public class KafkaMessageSource
extends Object
implements StreamableMessageSource<TrackedEventMessage<?>>

MessageSource implementation that reads messages from a Kafka topic.

Since:

3.0

Author:

Nakul Mishra

Constructor Summary

Constructors

Constructor and Description
KafkaMessageSource(Fetcher fetcher) Initialize the source using the given fetcher to retrieve messages from the Kafka topic

Method Summary

Modifier and Type	Method and Description
MessageStream<TrackedEventMessage<?>>	openStream(TrackingToken trackingToken) Open a stream containing all messages since given tracking token.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.axonframework.messaging.StreamableMessageSource

createHeadToken, createTailToken, createTokenAt, createTokenSince

Constructor Detail

KafkaMessageSource

public KafkaMessageSource(Fetcher fetcher)

Initialize the source using the given fetcher to retrieve messages from the Kafka topic

Parameters:

fetcher - The fetcher to retrieve messages from Kafka

Method Detail

openStream

public MessageStream<TrackedEventMessage<?>> openStream(TrackingToken trackingToken)

Description copied from interface: StreamableMessageSource

Open a stream containing all messages since given tracking token. Pass a trackingToken of null to open a stream containing all available messages. Note that the returned stream is infinite, so beware of applying terminal operations to the returned stream.

Specified by:

openStream in interface StreamableMessageSource<TrackedEventMessage<?>>

Parameters:

trackingToken - object containing the position in the stream or null to open a stream containing all messages

Returns:

a stream of messages since the given trackingToken