Package | Description |
---|---|
org.axonframework.boot.autoconfig | |
org.axonframework.kafka.eventhandling.consumer |
Class and Description |
---|
ConsumerFactory
The strategy to produce a
Consumer instance(s). |
Fetcher
Interface describing the component responsible for reading messages from Kafka.
|
KafkaMessageSource
MessageSource implementation that reads messages from a Kafka topic.
|
Class and Description |
---|
AsyncFetcher.Builder
Builder for the AsyncFetcher.
|
Buffer
Defines a buffer that wait for the space to become non-empty when retrieving an
element, and wait for space to become available in the buffer when
storing an element.
|
ConsumerFactory
The strategy to produce a
Consumer instance(s). |
Fetcher
Interface describing the component responsible for reading messages from Kafka.
|
KafkaEventMessage |
KafkaMetadataProvider
An interface for messages originating from Kafka capable of providing information about their source.
|
KafkaTrackingToken
Use to track messages consumed & committed from Kafka to Axon.
|
Copyright © 2010–2018. All rights reserved.