Skip to content

First Release for Neo4j v 4.0

Choose a tag to compare

View all tags
@neo-technology-build-agent neo-technology-build-agent released this 13 Mar 17:55
· 35 commits to 3.5 since this release
4.0.0
aa20992
This commit was created on GitHub.com and signed with GitHub’s verified signature. The key has expired.
GPG key ID: 4AEE18F83AFDEB23
Expired
Verified
Learn about vigilant mode.

Hi community!
We are very proud to share the first release of Streams Project for Neo4j 4.0 (here the docs).
This release supports the Multi database feature for sink and source in the following way.

Neo4j Streams: Source Module

You can set for each database instance a configuration suffix with the following pattern from.<DB_NAME> to the properties in your neo4j.conf file.

Following the list of new properties that allows to support multi-tenancy:

streams.source.topic.nodes.<TOPIC_NAME>.from.<DB_NAME>=<PATTERN>
streams.source.topic.relationships.<TOPIC_NAME>.from.<DB_NAME>=<PATTERN>
streams.source.enabled.from.<DB_NAME>=<true/false, default=true>
streams.procedures.enabled.<DB_NAME>=<true/false, default=true>

For more in-depth description, please got to the following doc page

Neo4j Streams: Sink Module

You can set for each database instance a configuration suffix with the following pattern to.<DB_NAME> to the properties in your neo4j.conf file.

Following the list of new properties that allows to support multi-tenancy:

streams.sink.topic.cypher.<TOPIC_NAME>.to.<DB_NAME>=<CYPHER_QUERY>
streams.sink.topic.cdc.sourceId.to.<DB_NAME>=<LIST_OF_TOPICS_SEPARATE_BY_SEMICOLON>
streams.sink.topic.cdc.schema.to.<DB_NAME>=<LIST_OF_TOPICS_SEPARATE_BY_SEMICOLON>
streams.sink.topic.pattern.node.<TOPIC_NAME>.to.<DB_NAME>=<NODE_EXTRACTION_PATTERN>
streams.sink.topic.pattern.relationship.<TOPIC_NAME>.to.<DB_NAME>=<RELATIONSHIP_EXTRACTION_PATTERN>
streams.sink.enabled.to.<DB_NAME>=<true/false, default=true>
streams.procedures.enabled.<DB_NAME>=<true/false, default=true>

For more in-depth description, please got to the following doc page

Multi Database Support

You can define into the json (or via the Confluent UI) a param named neo4j.database which is the targeted database name.

N.b. If no value is specified the connector will use the Neo4j's default db.

Assets 4
Loading