RUN APP
$ sbt runWorker APP dependents on reactiveJobQueue App. Before run worker app compile and do publish local to reactiveJobQueue.
$ cd reactiveJobQueue $ sbt publishLocalCreate kafka topic
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic uploadmessageCreate MySql database & Table.
Create database userdb;
Use userdb;
create table userinfo(id varchar(255) primary key,name varchar(255), time_of_start varchar(255));