卡夫卡client.keystore.jks基本的閱讀能力。

[Jayanth746]

以下是我們收到的錯誤當試圖讀

引起的:kafkashaded.org.apache.kafka.common.KafkaException:未能加載SSL密鑰庫/ dbfs / FileStore /證書/ client.keystore.jks

引起的:java.nio.file。NoSuchFileException: / dbfs / FileStore /證書/ client.keyst

當試圖讀卡夫卡的流,磚是無法找到密鑰存儲庫文件。

df =火花。readStream \

.format \(“卡夫卡”)

.option (“kafka.bootstrap。服務器”、“卡夫卡服務器和端口”)\

.option (“kafka.security。協議”、“SSL”) \

.option (“kafka.ssl.truststore.location”、“dbfs / FileStore /證書/ client.truststore。jks”) \

.option (“kafka.ssl.keystore。位置”,‘/ 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(“訂閱”、“體育”)\

.option (“startingOffsets”、“最早”)\

.load ()

文件存在於dbfs和也能夠讀取該文件。

[Debayan]

嗨@Jayanth Goulla,如此:kafka.ssl.keystore。類型= PEM ?

參考:https://docs.m.eheci.com/structured-streaming/kafka.html使用ssl

[Jayanth746]

嗨@Debayan穆克吉,請看到結果後使用PEM作為密鑰存儲庫類型。

引起的:kafkashaded.org.apache.kafka.common.errors.InvalidConfigurationException: SSL密鑰存儲密碼不能用PEM格式指定,隻能指定密鑰口令

我在聊天中使用文檔發布得到這個工作。

如果我使用SASL_SSL協議得到以下錯誤

引起的:. lang。IllegalArgumentException:找不到KafkaClient JAAS配置中的條目。係統屬性”java.security.auth.login。配置沒有設置

dbfs文件存在

[Debayan]

你必須構建JAAS文件和通過使用JVM選項。或者,你可以通過JAAS作為卡夫卡源選項的內容,說,動態JAAS配置。https://cwiki.apache.org/confluence/display/kafka/kip - 85% - 3 a +動+ JAAS +配置+ +卡夫卡+ cli……

[Jayanth746]

我需要使用JAAS,即使我已經對SSL連接有證書嗎?

我隻是想建立SSL連接,而不是SASL。