Skip to content

Latest commit

 

History

History
47 lines (38 loc) · 1.25 KB

README.md

File metadata and controls

47 lines (38 loc) · 1.25 KB
Raw

ckn-edge

How to run

Cloud system

This assumes you have docker installed. If not install docker via the docker website

  1. Run the following in the cloud system directory to persist the graph DB
mkdir -p system_data/neo4j_data
  1. Add the server IP to Kafka by changing the following in the docker-compose.yml file
KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:9092,PLAINTEXT_HOST://<SERVER_IP>:29092
  1. Start the cloud system
docker compose up
  1. Initialize the Kafka brokers for the required topics (for the incoming data)
sh ./init_scripts/create-kafka-topics.sh
  1. Add Kafka Connect connector for Aggregator Stream sink (Replace the server IP)
curl -X POST http://<SERVER_IP>:8083/connectors \
  -H "Content-Type:application/json" \
  -H "Accept:application/json" \
  -d @aggregated_sink.neo4j.json
  1. Add Kafka Connect connector for Server state sink (Replace the server IP)
curl -X POST http://<SERVER_IP>:8083/connectors \
  -H "Content-Type:application/json" \
  -H "Accept:application/json" \
  -d @model_sink.neo4j.json
  1. Run the Kafka Stream processor (jar file)
java -jar ckn-streaming-1.0-SNAPSHOT-jar-with-dependencies.jar