How it works 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. How to run 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
