This is a pubsub publisher for retail usecase on bigdata.
-
Install Java 8
-
Install Google Cloud SDK
-
To test your installation, open a terminal window and type:
$ java -version $ mvn --version $ gcloud --version
- Go to https://cloud.google.com/console.****
- Enable billing and create a project.
- Enable Google PubSub API
How to run the code, currently only project, topic and messages per second are supported variables
mvn compile exec:java \
-Dexec.mainClass=com.google.ce.demos.dataflow.abandonedcarts.producer.PublisherPubSub \
-Dexec.args="--project=YOUR_PROJECT \
--topic=YOUR_TOPIC \
--messagesPerSecond=MSGS_PER_SECOND \
--simulateAutoscaling=false
This project is licensed under the MIT License
mvn compile exec:java
-Dexec.mainClass=com.google.ce.demos.dataflow.abandonedcarts.producer.PublisherPubSub
-Dexec.args="--project=gricardo-brasil3
--topic=retailer-new-topic
--messagesPerSecond=10
--simulateAutoscaling=false"