I’m very excited about the features of Axon Framework and we want to use it for implementation of CQRS ES in our application.
I read a lot about different impplementation of event buses (including the discussion about the eventstore/eventbus and producer/consumer based messaging).
As far as I understand Kafka Messaging could be a perfect implementation for an event store (which means both: event distribution and storage) and would allow to replay events, if the query side intends to do so.
I found an implementation of a Kafka Terminal for Axon 2 (https://github.com/viadeo/axon-kafka-terminal) which seems to implement messaging only.
I would like to implement the Kafka Event store and looking for:
- Any feedback if this is a good idea
- Any progress someone made
- Any hints regarding the implementation -> what to look at and what to build on
- Any details, doubts or reports of someone who already tried that.
I think it is also a good idea to wait for Kafka 0.11 to be released (probably in few days), because it will support Record Header (https://cwiki.apache.org/confluence/display/KAFKA/KIP-82+-+Add+Record+Headers).
Thanks for your feedback in advance