earthquake_collector-mini

It pulls earthquake data from http://udim.koeri.boun.edu.tr/zeqmap/xmlt/son24saat.xml and writes it to a topic in Kafka if there is a new earthquake.

Kafka & Zookeeper & Scraper

Start :

cd deployment
docker-compose up --build

Stop:

cd deployment
docker-compose down -v --rmi all --remove-orphans

You You can see kafka posts events with commands to help. Bash:

docker exec -it kafka_eq  /bin/sh

EartQuake Comsumer:

kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic earthquake --from-beginning

EartQuake Producer:

kafka-console-producer.sh --broker-list localhost:9092 --topic earthquake