0. Install InsightEdge. Update the license file under $GS_HOME/gs-license.txt Modify the bin/set-gs-env.sh as required.

1. Install Kafka. Set the KAFKA_HOME environment variable.

2. Run bin/start-gs.sh script to start Gigaspaces

3. Run bin/start-kafka.sh

4. Run bin/deploy-gs.sh

5. Run bin/kafka-write-messages.sh to place data in Kafka topic.

6. Run com.gigaspaces.demo.kstreams.App Java program.

The Kafka StateStore example takes Kafka stream input in the form of a key: followed by text.

The key is used to uniquely identify a document stored in Gigaspaces. You can also think of it as a title of a document. With that we store a map that contains the words in the text and the counts.

For example: key:this is is a test

Creates the following data structure that gets stored to Gigaspaces. docId: key, map{ this=1, is=2, a=1, test=1, " "=4}