Skip to content

Commit 3458c75

Browse files
authored
Update contrib.sink.string-json.neo4j.json
1 parent 592ba10 commit 3458c75

File tree

1 file changed

+5
-2
lines changed

1 file changed

+5
-2
lines changed

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

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,9 @@
11
{
2-
"name": "Neo4jSinkConnector",
2+
"name": "Neo4jSinkConnectorJSON",
33
"config": {
4+
"key.converter": "org.apache.kafka.connect.storage.StringConverter",
5+
"value.converter": "org.apache.kafka.connect.json.JsonConverter",
6+
"value.converter.schemas.enable": false,
47
"topics": "my-topic",
58
"connector.class": "streams.kafka.connect.sink.Neo4jSinkConnector",
69
"errors.retry.timeout": "-1",
@@ -14,4 +17,4 @@
1417
"neo4j.encryption.enabled": false,
1518
"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)"
1619
}
17-
}
20+
}

0 commit comments

Comments
 (0)