Consumes the events beacon calls from kafka queue and stores into cassandra.

• Clone the repo
• git submodule init
• Perform bundle install

You need to create the topic in kafka before you can start listening to it. There are two ways to do it

• Run fakestream which will push messages into the topic thus creating the topic itself.
• Create a topic manually in kafka using default settings. Here is how to do it

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic events

ruby consumer.rb start

You can start multiple instances by running the above command multiple times.

ruby consumer.rb status

ruby consumer.rb stop

• Available at PROJ_DIR/shared/logs/
• Also check the logfile config at config/config.yml

FOREGROUND=true ruby consumer.rb