Margo – Media Ingest Service

Oct 2026

A media ingest service that checks videos before anyone can watch them and announces the approved ones on Kafka.

How Margo, Agnes, and Edith connect through Kafka, with the technologies each one uses — Margo, Edith, and Agnes, and how they fit together

Margo stands for Media Asset Routing & Governance Orchestrator. It's the front desk of a small simulated video streaming service, alongside Edith and Agnes.

What it does

Checks each video for a name, a real length, and a proper playlist file
Marks every video APPROVED or REJECTED, with a list of what went wrong
Announces the results on a Kafka topic, so Agnes only streams approved videos
Shows asset status and validation failures on a React and TypeScript dashboard
Handled a stress test of 10,000 videos

Built with: Java, Spring Boot, Apache Kafka, React, TypeScript, Docker

Code: github.com/marlware/margo