Kafka 的基本身份验证连接到访问架构注册表
我们已将Schema注册表和Kafka Connect设置为使用基本身份验证。一些连接器似乎正在运行。但其中一些出现错误：
" io . confluent . Kafka . schemaregistry . client . rest . exceptions . rest client exception:未授权；错误代码:401 "
如何给Kafka Connect提供模式注册的凭证？我应该在连接器配置或connect-distributed.properties中定义它吗？请注意，我可以毫无问题地使用GET之类的curl命令。
共有1个答案
哦，解决了，我会回答而不是删除，所以如果有人遇到同样的问题，他们可以很快找到解决办法。
您只需要添加几行连接分布式属性（或 -独立）。
schema.registry.basic.auth.user.info=user:pass
key.converter.basic.auth.user.info=user:pass
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:pass是模式注册表的登录凭据。
我不确定您是否必须添加键和值转换器行，但这样做是为了确保它是这样工作的。也让USER_INFO保持原样，不要忘记重新启动连接服务。
-
问题内容： Jsoup中是否可以通过基本访问身份验证从网站加载文档？ 问题答案： 使用HTTP基本访问身份验证时，您需要发送标头以及一个值。 例如（在Apache Commons Codec Base64的 帮助下）： （为了简便起见，省略了字符编码的明确说明，因为登录名和密码通常很简单；此外，Base64总是生成字节）
-
我正在开发一个使用Kafka代理和模式注册表的GCP云数据流作业。我们的Kafka broker和Schema Registry需要TLS客户端证书。我在部署时面临着与模式注册中心的连接问题。任何建议都非常欢迎。 这是我为数据流工作做的。我为TLS配置创建消费者属性。 并通过update Consumer Properties更新使用者属性。 正如这个stackoverflow答案所建议的，我还将
-
我一直在寻找使用各种AWS服务来处理我们下一个主要项目的基础设施。我们开始研究EC2实例上的docker容器，但在进一步研究AWS Lambda之后，这似乎是一条值得探索的道路。 使用AWS Lambda范例，我们只需使用Lambda函数作为逻辑粘合剂，将数据和事件（来自其他AWS服务）保存在一起。 例如，如果我们产品的用户创建了一个新记录，AWS Lambda可以在该事件中触发，我们可以调用La
-
我对confluent Kafka不熟悉，能够与Avro一起经营confluent Kafka及其制作人和消费者。在本指南的帮助下，我已使用这些命令注册了我的新架构： 以下是我的注册表python代码： 一切正常，我的制作人发送avro数据，我正在使用C#在我的客户机上接收数据。但现在我想用基本身份验证凭据实现模式注册表。出于这个原因，我在google上找到了这个链接，这让我很困惑。例如，它声明使
-
问题内容： 从HttpClient 4.3开始，我一直在使用HttpClientBuilder。我正在连接到具有基本身份验证的REST服务。我将凭据设置如下： 但是，这不起作用（我正在使用的REST服务返回401）。怎么了？ 问题答案： 从此处的 抢先身份验证 文档中： http://hc.apache.org/httpcomponents-client- ga/tutorial/html/aut
-
问题内容： 对于某些Django视图，我创建了一个执行基本HTTP访问身份验证的装饰器。但是，在用Django编写测试用例时，花了我一段时间来弄清楚如何对视图进行身份验证。这是我的方法。我希望有人觉得这有用。 问题答案： 这是我的做法： 注意：您还需要创建一个用户。