Helper functions for logging and metrics of streams - View it on GitHub