Hi all, Need your support. I am trying to use cdc with source id strategy and it's working fine with create and delete but not working with update. Update is working as a new node without updating old one with new declared label at configuration, but...
We are using neo4j 3.5.4 version. We have nearly 200 nodes and relationships. We want to capture all nodes and relationships data even for all CURD operations through Kafka . In neo4j .conf how I need to configure for all nodes and relationships fo...
As we know we can publish events with key in Kafka topic e.g. kafka-console-producer --topic key-value-topic --broker-list localhost:9092 --property "parse.key=true" --property "key.separator=:" key1:{value1} key2:{value2} key3:{value3} Is there a wa...
Hi. Hoping to get a little wisdom here as to whether this is a bug or something we've configured incorrectly. Using Neo4j 3.5 and sending to a Kafka topic using the streams capability. All seems to work well for creating and updating but we can't see...
I have a sink connector which consumes messages from KAFKA, I've configured poll records as 1000 by adding this property. "kafka.max.poll.records":1000 I just followed the documentation here. Neo4j Graph Database Platform ...
As per documentation, to use neo4j kafka stream connector, neo4j.conf is to be configure but how/where to do the same in case of neo4j aura. Moreover, if we want to used kafka connector instead of neo4j extension then how to define the connector uri ...
Hi. I am using Neo4j 4.2.3 together with the neo4j-streams-4.0.8 Plugin to stream Neo4j CDC events to a kafka topic. Works okay so far. Here is the question: It is quite possible that in some cases I lose everything what's in the topic (due to non-Ka...
Im trying to use sink connectotr to sync data from mongodb. I receive relationship event as, "fullDocument": { "_id": { "$oid": "6112376c9ade02082f500711" }, "_relatedFromId": "6112376b9ade02082f5006f6", "_relatedFromType": "PER...
How to specify a specific graph to connect to with integration neo4j with spark? I have multiple graphs like: There is no option given in official document to specify which graph to use while reading/ writing data.
Hello, I have configured neo4j and Kafka in K8s cluster (standalone). I'm using neo4j V4.1.3. I have configured neo4j as sink to consume JSON messages from Kafka topic. On sending the JSON message on a kafka topic, I don't see any debug message to in...
Hi Everyone, I am not able to run the "Stream" procedures and getting this error: Failed to invoke procedure `streams.consume`: Caused by: java.lang.NoSuchMethodError: 'java.io.File org.neo4j.io.layout.DatabaseLayout.databaseDirectory()' I am using ...
Hi, I'm experimenting with with the Kafka / Confluent Neo4j-Sink-Connector. What i wanted to achieve is to send data from MongoDB via Kafka to Neo4j. So far I have succeeded in merging and creating simple nodes and relationships with properties. Howe...
Hi all, i'm trying a super simple test integration between kafka and neo4j using neo4j sink plugin but simply not work. This are my test configuration: kafka.bootstrap.servers=127.0.0.1:9092 kafka.auto.offset.reset=earliest kafka.group.id=neo4j kafka...
One design question for my app where I've not understood if there is a Neo4J way of achieving the desired effect is.... As web based users create or delete nodes or relationships, in Neo4j through a web app, I want to kick off some Python scripts on ...
Experts, We have done the infra setup to transfer the incremental data from Oracle 12c to Neo4j 3.5.5 (RDMS <-> Oracle Golden Gate <-> Big Data Gold Gate <-> Kafka <-> Neo4j stream <-> Neo4j) And able to see the updated data under neo4j graph databas...
