获取 PKIX 路径构建失败，在使用 SSL 连接到Kafka群集时出现异常

Question

当我使用带SSL的apache camel连接到Kafka集群时，我面临以下问题，请任何人帮助解决这个问题

javax . net . SSL . SSL handshake异常:sun . security . validator . validator异常:PKIX路径构建失败:sun . security . provider . certpath . suncertpathbuilderexception:在sun . security . SSL . alerts . getsslexception(alerts . Java:192)在sun . security . SSL . SSL . sslsocketimpl . fatal(sslsocketimpl . Java:1937)上找不到请求目标的有效证书路径

这是加载.jks文件的正确方法吗？

  @Component
    public class MyRouteDefinition extends RouteBuilder {
    
    @Override
    public void configure() throws Exception {

        KeyStoreParameters ksp = new KeyStoreParameters();
        ksp.setType("jks");
        ksp.setResource("truststore.jks);
        ksp.setPassword("password");

        KeyManagersParameters kmp = new KeyManagersParameters();
        kmp.setKeyStore(ksp);
        kmp.setKeyPassword("password");

        TrustManagersParameters trustManagersParameters = new TrustManagersParameters();
        trustManagersParameters.setKeyStore(ksp);

        SSLContextParameters scp = new SSLContextParameters();
        scp.setKeyManagers(kmp);
        scp.setTrustManagers(trustManagersParameters);

        HttpComponent httpComponent = getContext().getComponent("https4", HttpComponent.class);
        httpComponent.setSslContextParameters(scp);

        //TO HTTPS
        from(...)
        .to("https://localhost:8080/load")
             log.debug("The response code is: {}", responseCode);
         }
    }

Answer 1

System.setProperty("javax.net.ssl.trustStore", "C:\\user\\myTrustStore"); 
System.setProperty("javax.net.ssl.trustStorePassword", "123456"); 

我找到了解决方案，从以上几条线来看，效果很好

Answer 2

使用HTTP时，客户端需要信任服务器。服务器发送证书以证明其身份。证书由CA（证书颁发机构）签署。客户端仅在识别签署其证书的CA时才信任服务器。如果CA存在于其信任库中，客户端将识别该CA。

如果证书未由CA签名，您也可以直接将证书导入信任库。

我猜你要么

1. 将签署服务器（侦听 localhost：8080 的 CA）证书的 CA 导入到客户机的信任库中
2. 将服务器的证书本身导入到信任库中。