Uses of Class
org.axonframework.kafka.eventhandling.consumer.AsyncFetcher.Builder

Packages that use AsyncFetcher.Builder

Package	Description
org.axonframework.kafka.eventhandling.consumer

Uses of AsyncFetcher.Builder in org.axonframework.kafka.eventhandling.consumer

Methods in org.axonframework.kafka.eventhandling.consumer that return AsyncFetcher.Builder

Modifier and Type	Method and Description
static <K,V> AsyncFetcher.Builder<K,V>	AsyncFetcher.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>	AsyncFetcher.builder(Map<String,Object> consumerConfig) Initialize a builder for configuring an AsyncFetcher, using given Kafka consumerConfig.
AsyncFetcher.Builder<K,V>	AsyncFetcher.Builder.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>	AsyncFetcher.Builder.withBufferFactory(Supplier<Buffer<KafkaEventMessage>> bufferFactory) Configure the factory for creating buffer that is used for each connection.
AsyncFetcher.Builder<K,V>	AsyncFetcher.Builder.withMessageConverter(KafkaMessageConverter<K,V> converter) Configure the converter which converts Kafka messages to Axon messages.
AsyncFetcher.Builder<K,V>	AsyncFetcher.Builder.withPollTimeout(long timeout, TimeUnit unit) Configure ExecutorService that uses Consumer for fetching Kafka records.
AsyncFetcher.Builder<K,V>	AsyncFetcher.Builder.withPool(ExecutorService sevice) Configure ExecutorService that uses Consumer for fetching Kafka records.
AsyncFetcher.Builder<K,V>	AsyncFetcher.Builder.withTopic(String topic) Configure Kafka topic to read events from.