- A pedometer app which measures the no. of steps taken by a user
- Sensor used: Accelerator
- Predicting the Calorie expense using Spark ML
- Consider Profile features like age, weight, height, gender etc
- Real time feed to Mobile App using Firebase
- Predicting the Feedback rating using TensorFlow.JS
- Predicting the flower name using TensorFlow LITE
- Android App
- Firebase real time db
- Kafka
- Spark Stream
- Dashboard
- Alexa
- Web interface and TensorJS Review sentiment
- TensorFlow Lite
- kf-step-detail - userid, dateon, steps
- kf-total-steps - userid, dateon, totalminutes, totalcalories, levels, miles
- kf-user-profile - userid, gender, age, weight, height
https://kafkapublisher-env.8tsy628pba.us-east-1.elasticbeanstalk.com/api/publish
Create Ubantu 16.4 EC2 M-Large Tier in AWS.
sudo apt-get update -y
sudo apt-get upgrade -y
sudo add-apt-repository -y ppa:webupd8team/java
sudo apt-get update
sudo apt-get install oracle-java8-installer -y
sudo java -version
sudo apt-get install zookeeperd
netstat -ant | grep :2181
wget https://archive.apache.org/dist/kafka/0.10.0.1/kafka_2.10-0.10.0.1.tgz
sudo mkdir /opt/Kafka
sudo tar -xvf kafka_2.10-0.10.0.1.tgz -C /opt/Kafka/
sudo /opt/Kafka/kafka_2.10-0.10.0.1/bin/kafka-server-start.sh /opt/Kafka/kafka_2.10-0.10.0.1/config/server.properties
sudo nohup /opt/Kafka/kafka_2.10-0.10.0.1/bin/kafka-server-start.sh /opt/Kafka/kafka_2.10-0.10.0.1/config/server.properties /tmp/kafka.log 2>&1 &
configuring server.properties
Open server.properties file in edit mode
sudo nano /opt/Kafka/kafka_2.10-0.10.0.1/config/server.properties
Uncomment and add public ip
advertised.listeners=PLAINTEXT:https://ec2-54-191-84-121.us-west-2.compute.amazonaws.com:9092
Start
#cd /opt/Kafka/kafka_2.10-0.10.0.1/
sudo /opt/Kafka/kafka_2.10-0.10.0.1/bin/kafka-server-start.sh /opt/Kafka/kafka_2.10-0.10.0.1/config/server.properties
Stop
sudo /opt/Kafka/kafka_2.10-0.10.0.1/bin/kafka-server-stop.sh
Create Topic
sudo /opt/Kafka/kafka_2.10-0.10.0.1/bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic testing
Delete the Topic
sudo /opt/Kafka/kafka_2.10-0.10.0.1/bin/kafka-topics.sh --zookeeper localhost:2181 --delete --topic testing
Zookeeper to List Topic
sudo /opt/Kafka/kafka_2.10-0.10.0.1/bin/kafka-topics.sh --list --zookeeper localhost:2181
Producer
sudo /opt/Kafka/kafka_2.10-0.10.0.1/bin/kafka-console-producer.sh --broker-list localhost:9092 --topic testing
Consumer
sudo /opt/Kafka/kafka_2.10-0.10.0.1/bin/kafka-console-consumer.sh --zookeeper localhost:2181 --topic testing --from-beginning
- Android App
User registration
User login
App Dashboard
Step counter
User Profile
User Progress
-
Firebase real time db
-
Kafka
-
Spark Stream
-
Alexa
-
Web interface, Dashboard, and TensorJS Review sentiment
-
TensorFlow Lite
Kafka Server Setup
Kafka remote enable
Kafka Consumer
Kafka Python
Kafka Java