磚< - >卡夫卡- SSL握手失敗了

[Jayanth746]

我接受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 ()

[Debayan]

嗨@Jayanth Goulla,值得一試,

https://stackoverflow.com/questions/54903381/kafka-failed-authentication-due-to-ssl-handshake-failed

你是:https://docs.microsoft.com/en-us/azure/databricks/spark/latest/structured-streaming/kafka嗎?

[Jayanth746]

嗨@Debayan穆克吉,我已經指定的選項.option \ (“kafka.ssl.endpoint.identification.algorithm”、“)。

我的錯誤是特定於簽名不匹配

java.security。SignatureException:簽名不匹配。

第二個鏈接不工作