Kafka integration


I’m thinking to use kafka as an event store or event bus. Since there is no implementation in the framework yet.
Could you please suggest how it can be done? Is there any example available

Best Regards,
Prawit Chaivong

The best option you have, I think, is to have a look at the existing implementations of the Event Bus. In case of an Event Store, you may want to implement an EventStorageEngine instead of an entire EventStore. You can use the JpaEventStorageEngine and JdbcEventStorageEngine as examples.

There is a project on GitHub that implemented a Kafka terminal for Axon 2: https://github.com/viadeo/axon-kafka-terminal
Maybe that can help you, too.