This example project shows a basic setup of Google Cloud Pub/Sub publisher / subscriber using Watermill. The application runs in a loop, consuming events from topic, modyfing them and publishing to another topic.
There's a docker-compose file included, so you can run the example and see it in action.
docker-compose up