org.axonframework.kafka.eventhandling.consumer

Class AsyncFetcher<K,V>

java.lang.Object

org.axonframework.kafka.eventhandling.consumer.AsyncFetcher<K,V>

Type Parameters:

K - The key of the Kafka entries

V - The value type of Kafka entries

All Implemented Interfaces:

Fetcher

public class AsyncFetcher<K,V>
extends Object
implements Fetcher

Async implementation of the Fetcher that uses an in-memory bufferFactory.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	AsyncFetcher.Builder<K,V> Builder for the AsyncFetcher.

Method Summary

Modifier and Type	Method and Description
static <K,V> AsyncFetcher.Builder<K,V>	builder(ConsumerFactory<K,V> consumerFactory) Initialize a builder for configuring an AsyncFetcher, using given consumerFactory for creating Kafka Consumers.
static <K,V> AsyncFetcher.Builder<K,V>	builder(Map<String,Object> consumerConfig) Initialize a builder for configuring an AsyncFetcher, using given Kafka consumerConfig.
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.

Methods inherited from class java.lang.Object

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

Method Detail

builder

public static <K,V> AsyncFetcher.Builder<K,V> builder(Map<String,Object> consumerConfig)

Initialize a builder for configuring an AsyncFetcher, using given Kafka consumerConfig.

Note that configuring a MessageConverter on the builder is mandatory if the value type is not byte[].

Type Parameters:

K - key type.

V - value type.

Parameters:

consumerConfig - The configuration of KafkaConsumers to use when creating consumers

Returns:

the builder.

builder

public static <K,V> AsyncFetcher.Builder<K,V> builder(ConsumerFactory<K,V> consumerFactory)

Initialize a builder for configuring an AsyncFetcher, using given consumerFactory for creating Kafka Consumers.

Note that configuring a MessageConverter on the builder is mandatory if the value type is not byte[].

Type Parameters:

K - key type.

V - value type.

Parameters:

consumerFactory - The factory providing Kafka Consumer instances

Returns:

the builder.

start

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

Description copied from interface: Fetcher

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

Specified by:

start in interface Fetcher

Parameters:

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

Returns:

a stream providing messages from Kafka

shutdown

public void shutdown()

Description copied from interface: Fetcher

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

Specified by:

shutdown in interface Fetcher