[streaming] Implemented mock persistent layer
[streaming] Added AckerTask