Update contrib.sink.avro.neo4j.json

conker84 · web-flow · commit 04d23137d87e · 2019-01-08T15:52:46.000+01:00
diff --git a/kafka-connect-neo4j/docker/contrib.sink.avro.neo4j.json b/kafka-connect-neo4j/docker/contrib.sink.avro.neo4j.json
@@ -12,6 +12,6 @@
     "neo4j.authentication.basic.username": "neo4j",
     "neo4j.authentication.basic.password": "connect",
     "neo4j.encryption.enabled": false,
-    "neo4j.topic.cypher.my-topic": "MERGE (p:Person{name: event.name, surname: event.surname}) MERGE (f:Family{name: event.surname}) MERGE (p)-[:BELONGS_TO]->(f)"
+    "neo4j.topic.cypher.my-topic": "MERGE (p:Person{name: event.name, surname: event.surname, from: 'AVRO'}) MERGE (f:Family{name: event.surname}) MERGE (p)-[:BELONGS_TO]->(f)"
   }
-}
+}

Original file line number	Diff line number	Diff line change
`@@ -12,6 +12,6 @@`
`12`	`12`	`"neo4j.authentication.basic.username": "neo4j",`
`13`	`13`	`"neo4j.authentication.basic.password": "connect",`
`14`	`14`	`"neo4j.encryption.enabled": false,`
`15`		`- "neo4j.topic.cypher.my-topic": "MERGE (p:Person{name: event.name, surname: event.surname}) MERGE (f:Family{name: event.surname}) MERGE (p)-[:BELONGS_TO]->(f)"`
	`15`	`+ "neo4j.topic.cypher.my-topic": "MERGE (p:Person{name: event.name, surname: event.surname, from: 'AVRO'}) MERGE (f:Family{name: event.surname}) MERGE (p)-[:BELONGS_TO]->(f)"`
`16`	`16`	`}`
`17`		`-}`
	`17`	`+}`