Domains
Contracts
Runs
Catalog tables
Source ownership
Domains & Events
Retail commerce is the starter domain. Replace it with your own source-system domains.
Producer agreements
Contracts
Contracts define topic, event, primary keys, and schema. These are the foundation for deduplication and lineage.
Process evidence
Ingestion Runs
Run the demo ingestion to see marker processing, deduplication, and catalog writes.
Historical layers
Catalog Layers
Intraday, endofday, and analytics layers model the journey from fresh ingest to reporting-ready data.
Traceability
Data & Process Lineage
Lineage connects source topics to tables and markers to processing steps.
Data lineage
Process lineage
Scoped answers
AI Assistant
Works without an API key using deterministic local context. Set OpenAI-compatible env vars for model-backed answers.
Make it yours
Adoption Guide
Use the template to model your own source systems and data products.
- Add your domain and event contracts in
demo/contracts.json. - Add Protobuf schemas under
contracts/protobuf/<domain>/. - Add event samples and marker files under
demo/. - Declare primary keys so ingestion can deduplicate records.
- Replace demo readers with Kafka and Iceberg adapters when moving beyond the template.