- A kafka consumer is started and messages are accepted in a special format.
- A memgraph client connects to Memgraph on port 7687.
- The consumer script parses the messages and inserts data from them to Memgraph using Cypher via the bolt protocol.
- Install requirements
pip install -r requirements.txt - Run kafka on port 9092, instructions
- Run memgraph on port 7687, instructions
- Run the app with
python app.py - Run a producer, instructions