This will be helpful to emit the most important failure logs in a single place in the code (which will make splunking way easier).

This probably requires operators throwing a StreamException which includes both unsafe and safe error messages.