Working streaming application - requires 1.0.0-SNAPSHOT (built locally)