我正在尝试在 Kafka Neo4j 连接器配置中将协议从螺栓更改为螺栓+路由。但是我面临错误
"trace":"java.lang.IllegalArgumentException: Invalid address format bolt+routing\n\tat org.neo4j.driver.internal.Scheme.validateScheme(Scheme.java:46)\n\tat org.neo4j.driver.internal.SecuritySettings.createSecurityPlan(SecuritySettings.java:64)\n\tat org.neo4j.driver.GraphDatabase.driver(GraphDatabase.java:138)\n\tat streams.kafka.connect.sink.Neo4jService.<init>(Neo4jService.kt:83)\n\tat streams.kafka.connect.sink.Neo4jSinkTask.start(Neo4jSinkTask.kt:29)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.initializeAndStart(WorkerSinkTask.java:308)\n\tat org.apache.kafka.connect.runtime.WorkerSinkTask.execute(WorkerSinkTask.java:199)\n\tat org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:185)\n\tat org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:235)\n\tat java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)\n\tat java.util.concurrent.FutureTask.run(FutureTask.java:266)\n\tat java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)\n\tat java.util.concurrent.-bash-4.3$ ps aux | grep java^C hread.run(Thread.java:748)\n"}
在回顾了一些东西之后,我对 Neo4j 驱动程序感到困惑。目前有 2 个 neo4j 驱动程序:Neo4j JDBC 驱动程序和 Neo4j Java 驱动程序。我只看到 Neo4j JDBC Driver 支持 bolt+routing,但 Neo4j Java Driver 不支持。我看到 Sink Connector 正在使用 Neo4j Java Driver,想知道如何在 Sink Connector 中使用 bolt+routing。
TIA