Implementing EventSourced Aggregates using Kafka as the backing Eventstore

A Kafka Message Source can consume events from a Kafka topic but how do I use those events as the repository for an Aggregate ?
Do I need to instead create an implementation of .with kafka backing it ?


Kafka is not a suitable implementation for an Event Store. For one, Kafka cannot validate uniqueness of sequence numbers. Also, reading events from a single aggregate is highly inefficient in Kafka.

That’s why in Axon, Kafka can be used as an Event Transport (for which it’s really good), but not as the Event Store.