Closed FrankR85 closed 4 years ago
FrankR85
commented
4 years ago Don't know if it is relevant but here is the snippet I use to call the procedure:
Driver driver = GraphDatabase.driver(uri, AuthTokens.none());
Session session = driver.session();
Result run = session.run(
"CALL streams.consume(\'my-topic\', {}) YIELD event"
+ " CREATE (p:Person{firstName: event.data.name, lastName: event.data.surname})");I want to add the information from the running Neo4j Container (started via a generic Testcontainer)
We upgraded to neo4j-streams:3.5.9 today.
What makes me wonder is that I don't see anything about Connecting to Kafka or similar in the log.
Do we have to activate the streams somehow?
Directories in use:
home: /var/lib/neo4j
config: /var/lib/neo4j/conf
logs: /logs
plugins: /var/lib/neo4j/plugins
import: NOT SET
data: /var/lib/neo4j/data
certificates: /var/lib/neo4j/certificates
run: /var/lib/neo4j/run
Starting Neo4j.
APOC couln't set a URLStreamHandlerFactory since some other tool already did this (e.g. tomcat). This means you cannot use s3:// or hdfs:// style URLs in APOC. This is caused by a limitation of the JVM which we cannot fix.
2020-09-02 13:15:43.163+0000 WARN Unrecognized setting. No declared setting with name: kafka.ssl.truststore.password
2020-09-02 13:15:43.166+0000 WARN Unrecognized setting. No declared setting with name: kafka.batch.size
2020-09-02 13:15:43.171+0000 WARN Unrecognized setting. No declared setting with name: streams.sink.dlq
2020-09-02 13:15:43.172+0000 WARN Unrecognized setting. No declared setting with name: kafka.acks
2020-09-02 13:15:43.172+0000 WARN Unrecognized setting. No declared setting with name: dbms.connector.bolt_address
2020-09-02 13:15:43.172+0000 WARN Unrecognized setting. No declared setting with name: kafka.ssl.keystore.location
2020-09-02 13:15:43.173+0000 WARN Unrecognized setting. No declared setting with name: kafka.auto.offset.reset
2020-09-02 13:15:43.173+0000 WARN Unrecognized setting. No declared setting with name: streams.sink.topic.cud
2020-09-02 13:15:43.176+0000 WARN Unrecognized setting. No declared setting with name: kafka.enable.ssl.certificate.verification
2020-09-02 13:15:43.176+0000 WARN Unrecognized setting. No declared setting with name: kafka.ssl.truststore.location
2020-09-02 13:15:43.177+0000 WARN Unrecognized setting. No declared setting with name: kafka.ssl.keystore.type
2020-09-02 13:15:43.178+0000 WARN Unrecognized setting. No declared setting with name: kafka.group.id
2020-09-02 13:15:43.178+0000 WARN Unrecognized setting. No declared setting with name: kafka.retries
2020-09-02 13:15:43.178+0000 WARN Unrecognized setting. No declared setting with name: kafka.ssl.truststore.type
2020-09-02 13:15:43.179+0000 WARN Unrecognized setting. No declared setting with name: kafka.security.protocol
2020-09-02 13:15:43.179+0000 WARN Unrecognized setting. No declared setting with name: streams.sink.enabled
2020-09-02 13:15:43.180+0000 WARN Unrecognized setting. No declared setting with name: streams.sink.topic.my-topic
2020-09-02 13:15:43.181+0000 WARN Unrecognized setting. No declared setting with name: kafka.bootstrap.servers
2020-09-02 13:15:43.181+0000 WARN Unrecognized setting. No declared setting with name: kafka.ssl.keystore.password
2020-09-02 13:15:43.182+0000 WARN Unrecognized setting. No declared setting with name: kafka.num.partitions
2020-09-02 13:15:43.182+0000 WARN Unrecognized setting. No declared setting with name: kafka.buffer.memory
2020-09-02 13:15:43.184+0000 INFO Starting...
2020-09-02 13:16:04.212+0000 INFO Initializing system graph model for component 'security-users' with version -1 and status UNINITIALIZED
2020-09-02 13:16:04.226+0000 INFO Setting up initial user from defaults: neo4j
2020-09-02 13:16:04.227+0000 INFO Creating new user 'neo4j' (passwordChangeRequired=true, suspended=false)
2020-09-02 13:16:04.253+0000 INFO Setting version for 'security-users' to 2
2020-09-02 13:16:04.262+0000 INFO After initialization of system graph model component 'security-users' have version 2 and status CURRENT
2020-09-02 13:16:04.279+0000 INFO Performing postInitialization step for component 'security-users' with version 2 and status CURRENT
2020-09-02 13:16:07.102+0000 INFO Called db.clearQueryCaches(): Query cache already empty.
2020-09-02 13:16:07.168+0000 INFO Bolt enabled on 0.0.0.0:7687.
2020-09-02 13:16:07.170+0000 INFO Started.Ok...stupid me... I shouldn't use Neo4j 4.1.1. with streams 3.x. Using streams-4.0.3 gives us Kafka Connect errors. Seems we are one step further.
I try to execute the example from the documentation §5.3:
This gives me the following exception:
What could be the cause of this issue? I'm running Neo4J locally with this config:
and this is my neo4j.conf:
Any ideas?