我接受SSL握手錯誤即使信任存儲區中我已經創建了基於服務器證書和證書的指紋與信任存儲指紋匹配。
kafkashaded.org.apache.kafka.common.errors.SslAuthenticationException: SSL握手失敗造成的:sun.security.validator。ValidatorException: PKIX路徑驗證失敗:java.security.cert。CertPathValidatorException:簽名檢查失敗造成的:java.security.cert。CertPathValidatorException:簽名檢查失敗造成的:java.security。SignatureException:簽名不匹配。
df =火花。readStream \
.format \(“卡夫卡”)
.option (“kafka.bootstrap.servers”、“XXXXXXXXXXXXXXXXXXXXXXXXXXXXXXXX”) \
.option (“kafka.security。協議”、“SSL”) \
.option (“kafka.ssl.truststore.location”、“/ dbfs / dbfs / FileStore /證書/ client.truststore1der。jks”)
.option (“kafka.ssl.keystore。位置”,“dbfs / dbfs / FileStore /證書/ client.keystore.jks”) \
.option (“kafka.ssl.keystore。密碼”,keystore_pass) \
.option (“kafka.ssl.truststore。密碼”,truststore_pass) \
.option (“kafka.ssl.keystore。類型”、“JKS”) \
.option (“kafka.ssl.truststore。類型”、“JKS”) \
.option \ (“kafka.ssl.endpoint.identification.algorithm”、“)
.option(“訂閱”,“押注”)\
.load ()