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

注冊表訪問彙合的模式從磚與scala失敗的401年(scala,不是python,隻是在磚)

alonisser
貢獻者

諾爾,我測試了相同的連接變量:

  1. 本地與scala -工作(通過相同的刺激模式注冊中心)
  2. 集群中的python -作品
  3. 集群中的scala -失敗與401年身份驗證錯誤
def setupSchemaRegistry (schemaRegistryUrl:字符串,confluentRegistryApiKey:字符串,confluentRegistrySecret:字符串):CachedSchemaRegistryClient = {val道具= (“basic.auth.credentials地圖。源”- >“USER_INFO”、“basic.auth.user.info”- >“$ confluentRegistryApiKey:美元confluentRegistrySecret”、“schema.registry.basic.auth.credentials。源”- >“USER_INFO”/ /嚐試這個版本就可以肯定的是“schema.registry。url”- > schemaRegistryUrl,“schema.registry.basic.auth.user.info”- >“$ confluentRegistryApiKey:美元confluentRegistrySecret”)。asJava / / val restService = new restService (schemaRegistryUrl) / /模式的格式注冊憑證下麵是confluentRegistryApiKey: confluentRegistrySecret println (s”模式注冊信息schemaRegistryUrl confluentRegistryApiKey美元$ confluentRegistrySecret ") / /也試過的版本,我通過restService內部相反,等新的CachedSchemaRegistryClient(100年schemaRegistryUrl道具)}val schemaRegistry = setupSchemaRegistry (schemaRegistryUrl、confluentRegistryApiKey confluentRegistrySecret) val res = schemaRegistry.getSchemaById(數量)/ /得到401

磚運行時:9.1

彙合的客戶機6.2.1

為什麼它會失敗在scala中,隻是從磚集群?我不能解釋!

我將會很高興任何幫助

1接受解決方案

接受的解決方案

alonisser
貢獻者

發現問題:超級包矯直一些依賴解決,我固定

另一個問題是,目前不能使用6。*的分支彙合的模式注冊客戶端在磚,因為avro版本是不同的火花3.1支持

在原帖子查看解決方案

2回答2

匿名
不適用

嗨@Alon nis -我的名字叫Piper我社區版主之一。歡迎和感謝你的問題。讓我們給這一段時間,看看社區說。

alonisser
貢獻者

發現問題:超級包矯直一些依賴解決,我固定

另一個問題是,目前不能使用6。*的分支彙合的模式注冊客戶端在磚,因為avro版本是不同的火花3.1支持

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

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

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

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

Baidu
map