You are developing an application on Google Cloud that involves processing a stream of data. The data needs to be consumed by multiple independent services for various processing tasks. Which of the following options is the best way to implement this system?