[streaming] integrating fault-tolerance layer into topology wip