我們已將 Schema Registry 和 Kafka Connect 設定為使用基本身份驗證。一些連接器可以毫無問題地從注冊表中提取模式。但其中一些給出了錯誤：
“io.confluent.kafka.schemaregistry.client.rest.exceptions.RestClientException：未經授權；錯誤代碼：401”
如何將架構注冊表的憑據提供給 Kafka Connect？我應該在連接器配置還是 connect-distributed.properties 中定義它？請注意，我可以毫無問題地使用諸如 GET 之類的 curl 命令。
uj5u.com熱心網友回復：
哦解決了，要回答而不是洗掉，所以如果有人遇到同樣的問題，他們可以快速找到解決方案。
您只需要在 connect-distributed.properties（或 -standalone）中添加幾行。
schema.registry.basic.auth.user.info=user:pass
key.converter.basic.auth.user.info=用戶：通行證
value.converter.basic.auth.user.info=user:pass
schema.registry.basic.auth.credentials.source=USER_INFO
key.converter.basic.auth.credentials.source=USER_INFO
value.converter.basic.auth.credentials.source=USER_INFO
我不確定您是否必須添加鍵和值轉換器行，但這樣做是為了確保它以這種方式作業。同時保留 USER_INFO 原樣，不要忘記重新啟動連接服務。
轉載請註明出處，本文鏈接：https://www.uj5u.com/caozuo/373464.html