neo4j-streams
neo4j-streams copied to clipboard
Neo4j Kafka Connector
1. MUST produce a document detailing the test environment, to include details including configuration on source/sink cluster setups, Kafka setup. 2. MUST produce a report showing proper instantiation of the...
* MUST provide single line CLI command to execute all unit tests. * Unit tests MUST print out human-readable report on test name and their pass/fail status. * Unit tests...
Use patterns to describe which parts of an event turn into a node/relationship. `streams.sink.topic.nodes.my-topic=:Person{name, email}`
https://developer.lightbend.com/docs/alpakka/current/
add an "out of the box" mechanism that uses some config/schema/convention for 1:1 mapping nodes and rels
Configurable with the following features: * `created:propName` * `updated:propName` * `createdBy:propName` * `updatedBy:propName` * `created(At)` * `updated(At)` * optional user * optional on relationships
In order to test the system with different Kafka versions
Patterns should allow defining custom id. Example: `Label1{!myCustomPropertyId}` For unique keys: `Label1{!(myCustomNodeKeyA,myCustomNodeKeyB)}`