git clone https://git.apache.org/samza-hello-samza.git hello-samza
cd hello-samza
git checkout latest
./bin/grid bootstrap
./bin/deploy.sh
./deploy/kafka/bin/kafka-topics.sh --zookeeper localhost:2181 --create --topic pageview-input --partitions 1 --replication-factor 1
./deploy/samza/bin/run-app.sh --config-factory=org.apache.samza.config.factories.PropertiesConfigFactory --config-path=file://$PWD/deploy/samza/config/my-samza-app.properties
./deploy/kafka/bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic my-output --property print.key=true
./deploy/kafka/bin/kafka-console-producer.sh --topic pageview-input --broker-list localhost:9092
{"userId": "jack", "country": "us", "pageId":"google.com"}
{"userId": "mary", "country": "sg", "pageId":"linkedin.com"}