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.