Hi all,
I’m currently working on a large-scale healthcare platform where openEHR is being used as the central system of record. We are exploring an event-driven architecture to support downstream consumers such as analytics pipelines, AI/ML services, and real-time clinical decision support.
I’d like to gather insights from others who have implemented or experimented with similar patterns.
Specifically:
- How are you emitting domain events from openEHR systems? (e.g., after commit, via CDC, or application layer hooks)
- Are there recommended patterns for maintaining consistency between openEHR and event streams?
- How do you handle eventual consistency concerns in clinical workflows?
- Any proven approaches for integrating AQL-based querying with streaming systems?
I’m currently evaluating Kafka-based pipelines and considering whether openEHR should remain purely transactional or also participate in streaming workflows.
Would appreciate any architectural patterns, pitfalls, or real-world experiences.
Thanks in advance.