This service handles persisting/storing the system-generated events into Cassandra event-store.
-
The event is consumed via Kafka topic (
event.rns_eventstore.events
). -
This event is then processed, which includes Marshalling it into Event model and inserting it into Cassandra Event-Store.
-
The post-processing result is published to a Kafka Topic (
event.persistence.response.<event-action>.<aggregate-id>
), which is based on Kafka-Response model. The event-producer must consume this result (by listening on the respective Kafka-Topic), check for errors, and proceed accordingly.
Check .env and docker-compose.yaml (docker-compose is only used in tests as of yet) files for default configurations (including the Cassandra Keyspace/Table used).