`Subprocess` that `online-ingestor` makes should be managed/limited. Also, we should attach a call back to commit each message that subprocess handles.