GCP Local Streaming Data Pipelines

This repository contains code samples used in this blog post. Please refer to the referenced article prior to executing any code here.

Starting All Three Emulators

. script/start-all

Or

source script/start-all

Stopping All Three Emulators

. script/stop-all

Or

source script/stop-all

Publishing Pre-defined Messages to the Pub/Sub Emulator

script/publisher $PUBSUB_PROJECT_ID publish my_emulated_topic