Services that incorporate streaming workloads often need to perform asynchronous
requests to other services, or execute long-running, asynchronous operations.
Examples include, inserting time-series data into a database, retrieving
metadata for data enrichment, and executing complex business-workflows.
Executing asynchronous operations in a streaming context, while maintaining
backpressure in the stream, is