[streaming] completed FTLayer, acking and replaying failed records