vishnu2497

Hi All, i am working on Kafka SFTP CSV Source Connector. i don't know how to authenticate using private key by using this below config,so for this issue no related...

Json Schema application Examples

1

In confluent site they mentioned like json ,avro ,protobuf examples will be available here.But here avro only is available. is json examples moves to some other place?

In this example you are using that avro file and creat that class automatically. so in most of the situation we need to create a class with the variables we...

Error Handling and recover using Streams.publish() in neo4j Streams?

2

Hi guys, we are working on neo4j streams to send the data from neo4j to kafka using this publish method. so what we are facing is while sending the data...

Neo4j streams cdc mechanism pulls the before data also which cause Space issue

1

## Bug Description Working on Neo4j Streams CDC by following this article https://neo4j.com/labs/kafka/4.0/producer/ but it is sending all the data to whatever we didn't configured also. ## Expected Behavior (Mandatory)...

Neo4j Streams is not sending the data to kafka when the kafka server is restarting

2

Hello Guys, The following is my neo4j.conf ``` streams.source.enabled=true streams.sink.enabled=false kafka.zookeeper.connect=localhost:2181 kafka.bootstrap.servers=localhost:9092 kafka.acks=1 kafka.num.partitions=1 kafka.retries=2 kafka.batch.size=16384 kafka.buffer.memory=33554432 kafka.reindex.batch.size=1000 kafka.session.timeout.ms=15000 kafka.connection.timeout.ms=10000 kafka.replication=1 kafka.linger.ms=1 kafka.client.id=testif23 kafka.topic.discovery.polling.interval=5000 streams.source.topic.nodes.neo4jfailtest=neo4jfailtest{*} streams.source.topic.nodes.neo4jfailtest1=neo4jfailtest1{*} apoc.import.file.enabled=true apoc.trigger.enabled=true streams.procedures.enabled=true dbms.security.procedures.whitelist=streams.*,apoc.*...

How to Send data from neo4j to kafka with some filtered data using neo4j streams?

7

Hi Guys, i am trying to send the data from neo4j to kafka using neo4j Streams. streams.source.enabled=true streams.sink.enabled=false kafka.zookeeper.connect=localhost:2181 kafka.bootstrap.servers=localhost:9092 kafka.acks=1 kafka.num.partitions=1 kafka.retries=2 kafka.batch.size=16384 kafka.buffer.memory=33554432 kafka.reindex.batch.size=1000 kafka.session.timeout.ms=15000 kafka.connection.timeout.ms=10000 kafka.replication=1 kafka.linger.ms=1...