org.axonframework.kafka.eventhandling.consumer

Class AsyncFetcher.Builder<K,V>

java.lang.Object

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

Type Parameters:

K - key type.

V - value type.

Enclosing class:

AsyncFetcher<K,V>

public static final class AsyncFetcher.Builder<K,V>
extends Object

Builder for the AsyncFetcher.

Method Summary

Modifier and Type	Method and Description
Fetcher	build() Builds the fetcher
AsyncFetcher.Builder<K,V>	onRecordPublished(BiFunction<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,KafkaTrackingToken,Void> callback) Configure Function to invoke once a ConsumerRecord is inserted into the Buffer.
AsyncFetcher.Builder<K,V>	withBufferFactory(Supplier<Buffer<KafkaEventMessage>> bufferFactory) Configure the factory for creating buffer that is used for each connection.
AsyncFetcher.Builder<K,V>	withMessageConverter(KafkaMessageConverter<K,V> converter) Configure the converter which converts Kafka messages to Axon messages.
AsyncFetcher.Builder<K,V>	withPollTimeout(long timeout, TimeUnit unit) Configure ExecutorService that uses Consumer for fetching Kafka records.
AsyncFetcher.Builder<K,V>	withPool(ExecutorService sevice) Configure ExecutorService that uses Consumer for fetching Kafka records.
AsyncFetcher.Builder<K,V>	withTopic(String topic) Configure Kafka topic to read events from.

Methods inherited from class java.lang.Object

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

Method Detail

withPool

public AsyncFetcher.Builder<K,V> withPool(ExecutorService sevice)

Configure ExecutorService that uses Consumer for fetching Kafka records. Note that the pool should contain sufficient threads to run the necessary fetcher processes concurrently.

Note that the provided pool will not be shut down when the fetcher is terminated.

Parameters:

sevice - ExecutorService.

Returns:

the builder.

onRecordPublished

public AsyncFetcher.Builder<K,V> onRecordPublished(BiFunction<org.apache.kafka.clients.consumer.ConsumerRecord<K,V>,KafkaTrackingToken,Void> callback)

Configure Function to invoke once a ConsumerRecord is inserted into the Buffer.

Parameters:

callback - function type.

Returns:

the builder.

withPollTimeout

public AsyncFetcher.Builder<K,V> withPollTimeout(long timeout,
                                                 TimeUnit unit)

Configure ExecutorService that uses Consumer for fetching Kafka records.

Parameters:

timeout - the timeout when reading message from the topic.

unit - the unit in which the timeout is expressed.

Returns:

this builder for method chaining.

withMessageConverter

public AsyncFetcher.Builder<K,V> withMessageConverter(KafkaMessageConverter<K,V> converter)

Configure the converter which converts Kafka messages to Axon messages.

Parameters:

converter - the converter.

Returns:

this builder for method chaining.

withTopic

public AsyncFetcher.Builder<K,V> withTopic(String topic)

Configure Kafka topic to read events from.

Parameters:

topic - the topic.

Returns:

this builder for method chaining.

withBufferFactory

public AsyncFetcher.Builder<K,V> withBufferFactory(Supplier<Buffer<KafkaEventMessage>> bufferFactory)

Configure the factory for creating buffer that is used for each connection.

Parameters:

bufferFactory - the bufferFactory.

Returns:

this builder for method chaining.

build

public Fetcher build()

Builds the fetcher

Returns:

the Fetcher