http://cloud.spring.io/spring-cloud-dataflow/
java -jar spring-cloud-dataflow-server-local-1.2.3.RELEASE.jar
brew install kafka
zookeeper-server-start /usr/local/etc/kafka/zookeeper.properties & kafka-server-start /usr/local/etc/kafka/server.properties
Download https://redis.io/download
cd redis-XX/
make
./src/redis-server
http://localhost:9393/dashboard
Apps -> Bulk import http://bit.ly/Bacon-RELEASE-stream-applications-kafka-10-maven
(1) dataflow:>stream create tweets --definition "twitterstream --consumerKey=<CONSUMER_KEY> --consumerSecret=<CONSUMER_SECRET> --accessToken=<ACCESS_TOKEN> --accessTokenSecret=<ACCESS_TOKEN_SECRET> | log"
Created new stream 'tweets'
(2) dataflow:>stream create tweetlang --definition ":tweets.twitterstream > field-value-counter --fieldName=lang --name=language" --deploy
Created and deployed new stream 'tweetlang'
(3) dataflow:>stream create tagcount --definition ":tweets.twitterstream > field-value-counter --fieldName=entities.hashtags.text --name=hashtags" --deploy
Created and deployed new stream 'tagcount'
(4) dataflow:>stream deploy tweets
Deployed stream 'tweets'
-
For real-time updates on language tags, select: Metric Type as Field-Value-Counters Stream as language Visualization as Bubble-Chart or Pie-Chart
-
For real-time updates on hashtags tags, select: Metric Type as Field-Value-Counters Stream as hashtags Visualization as Bubble-Chart or Pie-Chart