How to Model & Package data onto Kafka to be sinked into Neo4J - Noob

[joshcornejo]

If you want to run something on a unique identifier, you can use (this is simple):

  "ssn": "123-45-6789",
  "name": "Alice Smith",
  "age": 34,
  "city": "London"
}

MERGE (p:Person {ssn: $ssn})
SET p += {
  name: $name,
  age: $age,
  city: $city
}
ON CREATE
  SET p.created = timestamp(),
      p.updated = timestamp()
ON MATCH
  SET p.updated = timestamp()

Now you always have 1 node that identifies the accountHolder.