[streaming] source fault tolerance bugfix wip3: fixed source record anchoring and AckerCollector