Package org.axonframework.kafka.eventhandling.consumer

Interface Summary

Interface	Description
Buffer<E>	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<K,V>	The strategy to produce a Consumer instance(s).
Fetcher	Interface describing the component responsible for reading messages from Kafka.
KafkaMetadataProvider<V>	An interface for messages originating from Kafka capable of providing information about their source.

Class Summary

Class	Description
AsyncFetcher<K,V>	Async implementation of the Fetcher that uses an in-memory bufferFactory.
AsyncFetcher.Builder<K,V>	Builder for the AsyncFetcher.
ConsumerUtil	Utility for Consumer.
DefaultConsumerFactory<K,V>	The ConsumerFactory implementation to produce a new Consumer instance.
KafkaEventMessage
KafkaMessageSource	MessageSource implementation that reads messages from a Kafka topic.
KafkaMessageStream	Create message stream from a specific kafka topic.
KafkaTrackingToken	Use to track messages consumed & committed from Kafka to Axon.
SortedKafkaMessageBuffer<E extends Comparable & KafkaMetadataProvider>	Thread safe buffer for storing incoming Kafka messages in sorted order defined via Comparable.