Try Kill batch processing with unified log stream processing

This kind of basic abstraction in place gives us a way of gluing disparate data systems, processing real-time changes, as well as a being an interesting system and application architecture in its own right.