Kafka+Spark+Neo4j集成出现AuthenticationException认证异常求助

这个错误我之前帮不少开发者排查过，本质就是你的Spark Consumer连接Neo4j时没提供有效的认证信息，而Neo4j从3.0版本开始默认开启了认证机制，驱动尝试用无认证（scheme 'none'）的方式连接，直接被Neo4j拒绝了。下面是具体的排查和修复步骤：

1. 先搞懂错误根源 #

Neo4j的安全配置默认要求客户端必须提供用户名和密码才能建立连接。如果你的Spark配置里完全没指定认证参数，Neo4j Java Driver会自动使用none认证方案，而当Neo4j开启认证时，这个方案是不被允许的，所以就抛出了AuthenticationException。

2. 核心修复：补充Neo4j认证配置 #

在你的Spark Session配置里，加上Neo4j的用户名和密码参数就行。默认情况下，Neo4j的用户名是neo4j，密码是你第一次启动Neo4j时设置的（如果没改过，可能需要重新登录Neo4j Browser重置）。

示例代码修改 #

把你的main方法里的Spark配置部分更新成这样：

def main(args: Array[String]): Unit = {
  val spark = SparkSession.builder()
    .appName("KafkaSparkNeo4jConsumer")
    // 其他Spark/Kafka相关配置...
    .config("spark.neo4j.bolt.url", "bolt://your-neo4j-host:7687") // 替换成你的Neo4j地址
    .config("org.neo4j.driver.auth.username", "neo4j") // Neo4j默认用户名
    .config("org.neo4j.driver.auth.password", "your-neo4j-password") // 替换成你的实际密码
    .getOrCreate()

  // 后续的Kafka消费、Neo4j查询逻辑...
}

3. 其他可选排查方向 #

• 测试环境临时关闭认证：如果只是本地测试不想搞认证，可以修改Neo4j安装目录下的conf/neo4j.conf文件，把dbms.security.auth_enabled=true改成false，然后重启Neo4j服务。但生产环境绝对不能这么做，会有严重安全风险。
• 确认Bolt地址有效性：检查Neo4j的Bolt服务是否在指定的主机和端口运行（默认端口7687），防火墙有没有开放这个端口。
• 验证账号密码正确性：先用Neo4j Browser尝试登录，确认用户名和密码能正常进入，排除拼写错误的问题。

内容的提问来源于stack exchange，提问作者Cassie