Idempotent batch and continuous stream ingestion engine.

Validates producer envelopes, enforces sequence order, prevents duplicate event re-processing, projects into the domain, and forwards to online process miners.