cancel
Showing results for 
Search instead for 
Did you mean: 

Join the community at Nodes 2022, our free virtual event on November 16 - 17.

Neo4j kafka sink plugin

info15
Node

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.enable.auto.commit=true
kafka.key.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer
kafka.value.deserializer=org.apache.kafka.common.serialization.ByteArrayDeserializer
streams.sink.enabled=true
streams.sink.topic.cypher.DOMAIN-CIRCUIT=CREATE (n:Label)
errors.tolerance=all
errors.log.enable=true
errors.log.include.messages=true

Exploring kafka i can't see any consumer registered as neo4j (as i expect using kafka.group.id configuration)
There is any type of plugin log? I can't find any message inside neo4j logs except this 2 rows:

2021-05-04 16:53:49.973+0000 INFO  [neo4j/4e73b473] Starting the connector lifecycle listener
2021-05-04 16:53:49.975+0000 INFO  [neo4j/4e73b473] StreamsConfig started

Thanks for the help

0 REPLIES 0