我正在尝试将数据从烫发上的spark数据帧发布到云中的kafka主题。连接我有ssl证书（信任存储，密钥存储）。
但是我不知道如何使用Scala intellij中的证书进行连接。
示例代码将非常有帮助。
最佳答案
这与建立任何其他SSL连接相同。
将证书导入密钥库，并使用以下代码引用该密钥库
System.setProperty("javax.net.ssl.trustStore", "keystoreFilefullpath")
System.setProperty("javax.net.ssl.trustStorePassword", "password")
一旦设置了这些参数，则Kafka SSL应该可以使用。
如果从Spark发布，则必须使用--files选项将密钥库文件上传到驱动程序/执行程序