Kafka Connect - 如何限制创建、更新、删除特定连接器的权限
我面临的情况是，多个开发人员正在开发特定的kafka源或接收器连接器配置。连接器通过kafka connect REST API进行创建、更新、删除等操作。必须保证
- 开发人员从不删除或修改其他人的连接器。
- 开发人员只能管理特定连接器的
连接器.class例如“streams.kafka.connect.sink.Neo4jSinkConnector”
有什么方法可以配置Kafka，将Kafka-Connect REST API的使用限制在与连接器配置细节相关的特定操作上？kafka ACLs似乎没有涵盖这个用例。
共有1个答案
Kafka Connect提供具有用户名/密码支持的基本HTTP身份验证，但对于连接器的“所有权”或“有限管理”，不，该功能并不真正开箱即用。
为此，您需要实现自己的REST扩展。
资源：
- https://cwiki.apache.org/confluence/display/KAFKA/KIP-285:连接Rest扩展插件
- https://kafka.apache.org/documentation/#connectconfigs_rest.extension.classes
- https://github.com/apache/kafka/blob/3.2/connect/api/src/main/java/org/apache/kafka/connect/rest/ConnectRestExtension.java
或者创建自己的“代理服务器”来完成这项工作，并将请求转发给Connect API。
另一种选择是让上述开发人员部署和维护自己的Connect Cluster，例如通过Kubernetes中的容器或Terraform一些云虚拟机。
-
连接MySQL操作 mysql -h 主机地址 -u 用户名 －p 用户密码 注:-u与root可以不用加空格，其它参数也一样。 DEMO 打开电脑CMD,输入 mysql -h 127.0.0.1 -u root -p 回车，然后输入密码。就可以连接到本地的MySQL数据库。 创建MySQL用户 CREATE USER 'username'@'host' IDENTIFIED BY 'passw
-
问题内容： 最近，Google自动合并了Google服务对最终版本apk的许可。有人问这里，为什么包括Google Play服务库时权限会自动添加到我的AndroidManifest中 我的问题是不需要某些权限，我也不想在我的应用程序中使用某些敏感权限。那么如何删除像 android.permission.ACCESS_COARSE_LOCATION 这样的权限？使用gradle build，我不
-
问题内容： 我有一个动作和减速器，可以更新全局计数器。快速执行此操作。减速器为每个操作返回状态的新副本。减速器看起来像： 我在各种React组件上使用的方法。并非所有组件都关心此循环计数器。因为我在每个刻度上都在化简器中返回新状态，所以所有订阅的组件都将执行，这会导致不必要的React渲染调用。 这些组件之一如下所示： 即使此组件不依赖它，也会触发重新渲染。这会导致重新渲染，过度渲染，多次渲染，不
-
本文向大家介绍MongoDB的创建、更新和删除，包括了MongoDB的创建、更新和删除的使用技巧和注意事项，需要的朋友参考一下 概要 下面开始学习MongoDB最重要也是最基础的部分：C（创建）R（查询）U（更新）D（删除）；由于R（查询）操作相对来说内容比较多，也比较繁琐， 同时使用频率也比较高，所以下一篇会拿出来单独介绍。废话不多说，连上服务器，我们直接进入正题！ 一、创建 按照我
-
我参考了以下链接来了解Kafka的HDFS连接https://docs.confluent.io/2.0.0/Connect/connect-hdfs/docs/index.html 我能够通过配置单元集成将数据从Kafka导出到HDFS。 现在我正尝试在Java程序的帮助下将avro记录写入Kafka 当我把Avro记录写到Kafka主题时，我在Connect中出现以下错误
-
我使用Spring Boot开发了一个微服务。我是通过拦截后端调用来测试服务的性能。当我查看线程计数时，我看到在任何时间点上为服务创建的最大线程数是20个，尽管所发出的调用数要高得多。对使用Spring Boot开发的微服务的调用次数是否有限制。请您指导我需要遵循哪些步骤来排除故障/增加服务接受的连接数？