Uses of Interface
org.axonframework.kafka.eventhandling.consumer.Buffer

Packages that use Buffer

Package	Description
org.axonframework.kafka.eventhandling.consumer

Uses of Buffer in org.axonframework.kafka.eventhandling.consumer

Classes in org.axonframework.kafka.eventhandling.consumer that implement Buffer

Modifier and Type	Class and Description
class	SortedKafkaMessageBuffer<E extends Comparable & KafkaMetadataProvider> Thread safe buffer for storing incoming Kafka messages in sorted order defined via Comparable.

Method parameters in org.axonframework.kafka.eventhandling.consumer with type arguments of type Buffer

Modifier and Type	Method and Description
AsyncFetcher.Builder<K,V>	AsyncFetcher.Builder.withBufferFactory(Supplier<Buffer<KafkaEventMessage>> bufferFactory) Configure the factory for creating buffer that is used for each connection.

Constructors in org.axonframework.kafka.eventhandling.consumer with parameters of type Buffer

Constructor and Description
KafkaMessageStream(Buffer<KafkaEventMessage> buffer, Runnable closeHandler)