| Package | Description |
|---|---|
| org.axonframework.boot.autoconfig | |
| org.axonframework.kafka.eventhandling.consumer |
| Modifier and Type | Method and Description |
|---|---|
Fetcher |
KafkaAutoConfiguration.kafkaFetcher(ConsumerFactory<String,byte[]> consumerFactory,
KafkaMessageConverter<String,byte[]> messageConverter) |
| Modifier and Type | Method and Description |
|---|---|
KafkaMessageSource |
KafkaAutoConfiguration.kafkaMessageSource(Fetcher fetcher) |
| Modifier and Type | Class and Description |
|---|---|
class |
AsyncFetcher<K,V>
Async implementation of the
Fetcher that uses an in-memory bufferFactory. |
| Modifier and Type | Method and Description |
|---|---|
Fetcher |
AsyncFetcher.Builder.build()
Builds the fetcher
|
| Constructor and Description |
|---|
KafkaMessageSource(Fetcher fetcher)
Initialize the source using the given
fetcher to retrieve messages from the Kafka topic |
Copyright © 2010–2018. All rights reserved.