注冊表訪問彙合的模式從磚與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中,隻是從磚集群?我不能解釋!

我將會很高興任何幫助

[匿名]

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

[alonisser · Accepted solution]

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

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