- 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.
- Create go repository
go mod init memgraph.com/streaming-app
- Install dependencies
go mod tidy
- Run kafka on port 9092, instructions
- Run memgraph on port 7687, instructions
- Run the app with
go run app.go
- Run a producer, instructions