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