Vert.x Kerberos认证编译失败：io.vertx.ext.auth.kerberos包已不可用

1. 确认依赖配置 #

首先确保项目引入了正确的Vert.x Kerberos认证模块，以Maven为例，添加以下依赖（替换为你的Vert.x版本）：

<dependency>
    <groupId>io.vertx</groupId>
    <artifactId>vertx-auth-kerberos</artifactId>
    <version>4.5.1</version>
</dependency>
<dependency>
    <groupId>io.vertx</groupId>
    <artifactId>vertx-web-client</artifactId>
    <version>4.5.1</version>
</dependency>

2. 修正代码中的过时API #

你原代码中使用的KerberosOptions和WebClient.authKerberos()方法已被废弃或移除，以下是更新后的完整代码：

import io.vertx.core.AbstractVerticle;
import io.vertx.core.Promise;
import io.vertx.core.json.JsonObject;
import io.vertx.ext.auth.User;
import io.vertx.ext.auth.kerberos.KerberosAuth;
import io.vertx.ext.auth.kerberos.KerberosAuthOptions;
import io.vertx.ext.web.client.HttpRequest;
import io.vertx.ext.web.client.WebClient;
import io.vertx.ext.web.client.WebClientOptions;

public class KerberosVerticle extends AbstractVerticle {

    @Override
    public void start(Promise<Void> startPromise) {
        WebClient webClient = createWebClient();
        KerberosAuth kerberosAuth = createKerberosAuth();

        // 先完成Kerberos认证，再发送请求
        kerberosAuth.authenticate(new JsonObject(), authRes -> {
            if (authRes.succeeded()) {
                User user = authRes.result();
                HttpRequest<String> request = webClient.getAbs("https://example-kerberos-protected-api.com/resource");
                // 将认证凭据注入请求
                user.injectCredentials(request);

                request.send(response -> {
                    if (response.succeeded()) {
                        System.out.println("Response: " + response.result().bodyAsString());
                        startPromise.complete();
                    } else {
                        response.cause().printStackTrace();
                        startPromise.fail(response.cause());
                    }
                });
            } else {
                authRes.cause().printStackTrace();
                startPromise.fail(authRes.cause());
            }
        });
    }

    private WebClient createWebClient() {
        WebClientOptions options = new WebClientOptions()
                .setSsl(true)
                .setUseAlpn(true)
                .setTrustAll(true); // 生产环境请替换为实际的信任证书配置

        return WebClient.create(vertx, options);
    }

    private KerberosAuth createKerberosAuth() {
        return KerberosAuth.create(vertx, new KerberosAuthOptions()
                .setKrb5Config("/etc/krb5.conf") // 挂载的krb5.conf路径
                // 若使用keytab认证，添加以下配置（根据实际情况调整）
                .setKeytab("/etc/security/keytabs/client.keytab")
                .setPrincipal("client-service@EXAMPLE.COM"));
    }
}

3. 关键说明 #

• 认证流程调整：原代码直接在WebClient上绑定Kerberos配置的方式已不再支持，现在需要先通过KerberosAuth完成认证获取User实例，再将凭据注入到具体请求中。
• Kerberos配置项：
  • krb5Config：指定挂载的krb5.conf文件路径，确保Pod内该路径可访问且权限正确。
  • Keytab和Principal：如果使用keytab方式认证（K8s环境推荐），需要将客户端keytab文件也挂载到Pod中，并配置对应的服务主体名。
• SSL配置：setTrustAll(true)仅用于测试，生产环境需配置setTrustStoreOptions指定信任证书存储。

4. K8s环境额外检查 #

• 确认krb5.conf和keytab文件已正确挂载到Pod的指定路径，可通过kubectl exec进入Pod验证文件存在且可读。
• 确保Pod所在网络能访问Kerberos KDC服务器，端口默认是88（UDP/TCP）。

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