- 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 neo4j from nuget
dotnet add package Neo4j.Driver.Simple
- Install kafka from nuget
dotnet add package Confluent.Kafka
- Run kafka on port 9092, instructions
- Run memgraph on port 7687, instructions
- Run the app with
dotnet run
- Run a producer, instructions