Uses of Class
org.axonframework.kafka.eventhandling.consumer.KafkaEventMessage

Packages that use KafkaEventMessage

Package	Description
org.axonframework.kafka.eventhandling.consumer

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

Methods in org.axonframework.kafka.eventhandling.consumer that return KafkaEventMessage

Modifier and Type	Method and Description
static KafkaEventMessage	KafkaEventMessage.from(EventMessage<?> eventMessage, org.apache.kafka.clients.consumer.ConsumerRecord<?,?> record, KafkaTrackingToken token)

Methods in org.axonframework.kafka.eventhandling.consumer with parameters of type KafkaEventMessage

Modifier and Type	Method and Description
int	KafkaEventMessage.compareTo(KafkaEventMessage other) Compares ConsumerRecord based on timestamp.

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

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.

Constructor parameters in org.axonframework.kafka.eventhandling.consumer with type arguments of type KafkaEventMessage

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