Kafka Neo4j Connect - 使用螺栓+路由协议

如何解决Kafka Neo4j Connect - 使用螺栓+路由协议

我正在尝试将 Kafka Neo4j 连接器配置中的协议从 bolt 更改为 bolt+routing。但是我正面临错误

"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 Driver和Neo4j Java Driver。我只看到 Neo4j JDBC Driver 支持 bolt+routing，但 Neo4j Java Driver 不支持。我看到 Sink Connector 正在使用 Neo4j Java Driver，想知道我们如何在 Sink Connector 中使用 bolt+routing。

TIA

已解决：使用 neo4j 协议代替 bolt+routing。效果很好