org.axonframework.kafka.eventhandling.consumer

Interface Fetcher

All Known Implementing Classes:

AsyncFetcher

public interface Fetcher

Interface describing the component responsible for reading messages from Kafka.

Author:

Nakul Mishra

Method Summary

Modifier and Type	Method and Description
void	shutdown() Shuts the fetcher down, closing any resources used by this fetcher.
MessageStream<TrackedEventMessage<?>>	start(KafkaTrackingToken token) Open a stream of messages, starting at the position indicated by the given token.

Method Detail

start

MessageStream<TrackedEventMessage<?>> start(KafkaTrackingToken token)

Open a stream of messages, starting at the position indicated by the given token.

Parameters:

token - the token representing positions of the partition to start from

Returns:

a stream providing messages from Kafka

shutdown

void shutdown()

Shuts the fetcher down, closing any resources used by this fetcher.