Changed handling of stream reading errors. Now the stream consumers are closed, not retried