Kafka如何在没有访问本地文件系统的情况下配置PKCS12`ssl.keystore.location=user.p12`？

如果Kafka服务器无法访问本地文件系统，可以使用Java KeyStore API将PKCS12文件转换为Java密钥存储库，然后将其嵌入到Kafka服务器的JAR文件中。

以下是示例代码来将PKCS12文件转换为Java密钥存储库：

private KeyStore getKeyStoreFromPkcs12File(InputStream pkcs12FileInputStream, char[] password) throws Exception {
    KeyStore ks = KeyStore.getInstance("PKCS12");
    ks.load(pkcs12FileInputStream, password);
    return ks;
}

private void createKeyStoreFile(KeyStore ks, String fileName, char[] password) throws Exception {
    FileOutputStream fos = new FileOutputStream(fileName);
    ks.store(fos, password);
    fos.close();
}

private void convertPkcs12ToJavaKeyStore(String pkcs12FilePath, char[] pkcs12FilePassword, String keyStoreFilePath, char[] keyStorePassword) throws Exception {
    FileInputStream pkcs12InputStream = new FileInputStream(pkcs12FilePath);

    KeyStore pkcs12KeyStore = getKeyStoreFromPkcs12File(pkcs12InputStream, pkcs12FilePassword);
    pkcs12InputStream.close();

    KeyStore javaKeyStore = KeyStore.getInstance(KeyStore.getDefaultType());
    javaKeyStore.load(null, keyStorePassword);

    Enumeration<String> aliases = pkcs12KeyStore.aliases();

    while (aliases.hasMoreElements()) {
        String alias = aliases.nextElement();
        javaKeyStore.setKeyEntry(alias, pkcs12KeyStore.getKey(alias, pkcs12FilePassword), keyStorePassword, pkcs12KeyStore.getCertificateChain(alias));
    }

    createKeyStoreFile(javaKeyStore, keyStoreFilePath, keyStorePassword);
}

使用上述方法，可以将PKCS12文件转换为Java密钥存储库。然后，将密钥存储库嵌入Kafka服务器的JAR文件中，并在Kafka配置文件中指定密钥存储库的路径：

ssl.keystore.location=classpath:user.jks
ssl.keystore.password=<keystore