取消
顯示的結果
而不是尋找
你的意思是:

未能初始化azure-event-hub azure的廣告(服務主體)

Ravikumashi
新的貢獻者三世

我們一直試圖驗證azure-event-hub azure的廣告(服務主體),而不是共享訪問密鑰(連接字符串)和從azure-event-hub讀取事件,未能初始化azure-event-hubs。異常和投擲沒有這樣的方法。

我將全部錯誤的截圖。

錯誤信息完整從錯誤中我可以看到因為scala運行時的兼容性,可以有人幫我做這個嗎?我不確定如果我錯過一些東西。

以下是我的配置:

  1. 我用10.4 LTS磚運行的時間。
  2. Azure服務原則Azure事件中心數據接收方的許可
  3. 依賴於10.4 LTS後安裝

com.microsoft.azure: azure-eventhubs-spark_2.12:2.3.22

com.microsoft.azure: msal4j: 1.10.1

4所示。試圖實施方案中給出下麵的存儲庫。

https://github.com/Azure/azure-event-hubs-火花/團/主/ docs / use-aad -authentication-to-connect-eventhubs.md&

https://github.com/alexott/databricks-playground/tree/main/kafka-eventhubs-aad-auth/src/main/java/ne..。

@Alex奧特請您能幫助

6個回答6

alexott
價值貢獻
價值貢獻

隻會執行命令從存儲庫(不要使用azure文檔):

  1. 建立正確的配置文件
  2. 安裝正確的依賴關係
  3. 配置按照readme

我已經測試了它在10.4,一切都工作得很好

Ravikumashi
新的貢獻者三世

@Alex奧特謝謝你的回複,我在scala實現,建議在這種情況下嗎?

我添加了ServicePrincipalCredentialsAuth和ServicePrincipalAuthBase正常類在scala的祖國,而不是創建一個單獨的jar為這兩類和包裝作為我的項目jar的一部分

配置和使用以下代碼。

val參數:地圖(字符串,字符串)=(“權威”- > dbutils.secrets地圖。得到(=“nykvsecrets”範圍,鍵=“ehaadtesttenantid”),

“clientId”- > dbutils.secrets。得到(=“nykvsecrets”範圍,鍵=“ehaadtestclientid”),

“clientSecret”- > dbutils.secrets。得到(=“nykvsecrets”範圍,鍵=“ehaadtestclientsecret”))

val connectionString = ConnectionStringBuilder ()

.setAadAuthConnectionString(新URI (“your-ehs-endpoint”)、“your-ehs-name”)

.build

val ehConf = EventHubsConf (connectionString)

.setConsumerGroup (“consumerGroup”)

.setAadAuthCallback(新ServicePrincipalCredentialsAuth (params))

.setAadAuthCallbackParams (params)

任何問題你看到嗎?

Ravikumashi
新的貢獻者三世

@Alex奧特我們有相當於scala回購嗎?

不,我專門為我選擇Java作為實現語言的庫來避免Scala版本問題,等等。

歡迎來到磚社區:讓學習、網絡和一起慶祝

加入我們的快速增長的數據專業人員和專家的80 k +社區成員,準備發現,幫助和合作而做出有意義的聯係。

點擊在這裏注冊今天,加入!

參與令人興奮的技術討論,加入一個組與你的同事和滿足我們的成員。

Baidu
map