Skip to content

Commit 7e61c00

Browse files
authored
Update contrib.sink.string-json.neo4j.json
1 parent 04d2313 commit 7e61c00

File tree

1 file changed

+1
-1
lines changed

1 file changed

+1
-1
lines changed

kafka-connect-neo4j/docker/contrib.sink.string-json.neo4j.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -15,6 +15,6 @@
1515
"neo4j.authentication.basic.username": "neo4j",
1616
"neo4j.authentication.basic.password": "connect",
1717
"neo4j.encryption.enabled": false,
18-
"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)"
18+
"neo4j.topic.cypher.my-topic": "MERGE (p:Person{name: event.name, surname: event.surname, from: 'JSON'}) MERGE (f:Family{name: event.surname}) MERGE (p)-[:BELONGS_TO]->(f)"
1919
}
2020
}

0 commit comments

Comments
 (0)