neo4j-streams

neo4j-streams copied to clipboard

Update readme

2

Include deprecation notice of the server extension and correct documentation link

rossdeane

Local setup of Kafka to Neo4j by using Docker

4

## Guidelines Please note that GitHub issues are only meant for bug reports/feature requests. If you have questions on how to use Streams, please ask on [StackOverflow](https://stackoverflow.com/questions/tagged/neo4j-streams) instead of creating...

maheshtati441

Route all node/relationships to a topic

2

We need to manage cases like this for both nodes/relationships: streams.source.topic.relationships.={*} So if I want to track CDC on Neo4j and someone adds a new relationship, that will sent out...

conker84

Relationships creation not working

8

Hello, I have an issue with the relationship creation apoc : `apoc.create.relationship` I used this cypher query to create the relationship : ``` streams.sink.topic.cypher.relationships-topic.to.test-db2=MATCH (child),(parent) WHERE child.id=event.child AND parent.id=event.parent CALL...

aissaelouafi

4.1.x plugin not working on neo4j 4.3 or 4.2

1

## Expected Behavior (Mandatory) upon modifying a property in neo, a CDC event should get sent to the configured Kafka topic. ## Actual Behavior (Mandatory) CDC messages are not simply...

alphadever

Neo4j Source connector (a Kafka Connect plugin) uses timestamp parameter to figure out the new/updated entities. Every Neo4j entity must have this parameter. The Source connector retrieves based on the...

viveksaran71

Please add a feature which will replace the usage of the `readTransaction` function (into the Neo4jSourceService.kt class) with a `writeTransaction` so that users can provide a cypher query with also...

viveksaran71

A scan of neo4j-streams-3.5.13.jar has shown security vulnerabilities with the following: 50 (com.fasterxml.jackson.core_jackson-databind, 2.9.7) 5 (io.netty_netty, 3.9.9.Final) 4 (org.apache.commons_commons-compress, 1.8.1) This issue has been reported in the following Zendesk ticket:...

mroiter-larus

Add message key and headers to the Cypher ingestion strategy

1

Several customers asked about having access to the Kafka message key and headers in the Cypher query Strategy. In order to preserve backwards compatibility, we leave `$event` as-is and we'll...

conker84

Strange behavior of the streams.publish procedure inside apoc.periodic.repeat procedure

3

Please note that GitHub issues are only meant for bug reports/feature requests. If you have questions on how to use Streams, please ask on [StackOverflow](https://stackoverflow.com/questions/tagged/neo4j-streams) instead of creating an issue...

doctor3030