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

[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回購嗎?

[alexott]

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