未能初始化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奧特請您能幫助

[Ravikumashi]

我認為這是現在工作。我想做什麼,這是不正確的在這種情況下,試圖測試這段代碼直接在磚scala的筆記本安裝庫com.microsoft.azure: azure-eventhubs-spark_2.12:2.3.22 & com.microsoft.azure: msal4j: 1.10.1在集群上並沒有因為幾乎沒有丟失的編譯時庫/包附帶azure-event-hubs-spark和msal4j庫。

scala我不得不做些小的語法變化。它開始工作。

非常感謝。

[arun_28]

嘿,拉維,

你能請提供的步驟!或任何Scala中的示例代碼。

我們也打算做同樣的和麵臨的問題。

謝謝,

阿倫G