Package | Description |
---|---|
org.axonframework.boot.autoconfig | |
org.axonframework.kafka.eventhandling.consumer |
Modifier and Type | Method and Description |
---|---|
ConsumerFactory<String,byte[]> |
KafkaAutoConfiguration.kafkaConsumerFactory() |
Modifier and Type | Method and Description |
---|---|
Fetcher |
KafkaAutoConfiguration.kafkaFetcher(ConsumerFactory<String,byte[]> consumerFactory,
KafkaMessageConverter<String,byte[]> messageConverter) |
Modifier and Type | Class and Description |
---|---|
class |
DefaultConsumerFactory<K,V>
The
ConsumerFactory implementation to produce a new Consumer instance. |
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. |
Copyright © 2010–2018. All rights reserved.