我需要为REST API创建kafka源连接器与头部身份验证，如curl -H "Authorization: Basic“-H "clientID：”"https:< url for source>我使用的是apache kafka，我使用的是连接器类com.github.castorm.kafka.connect.http.HttpSourceConne
浏览 14提问于2020-09-06得票数 0
回答已采纳
Kafka Connect的REST API未经过安全和身份验证。由于它未经过身份验证，因此任何人都可以轻松访问连接器或任务的配置。由于这些配置可能包含在SourceConnector情况下如何访问源系统，在SinkConnector情况下如何访问目标系统，是否有标准方法来限制对这些API的访问？
浏览 0提问于2017-07-22得票数 10
我正在使用Landoop Kafka docker图像。我使用它的UI来创建jdbc源和jdbc接收器连接器，或者我也可以使用Kafka Rest Api来创建连接器。我有多个jdbc源连接器使用相同的连接url、用户名和密码。无论何时更改源数据库凭据，目前我都必须单独更改所有连接器。有没有办法只外部化这些属性，让每个连接器都有自己的</
浏览 0提问于2018-12-14得票数 0
卡夫卡流是好的，但我必须做每一个配置非常手动。相反，Kafka提供了它的API接口，它对于处理配置以及任务、工作人员等都非常有用。
因此，我正在考虑在我的简单数据转换服务中使用Kafka。基本上，服务将从一个主题读取数据，并将转换后的数据发送到另一个主题。为了做到这一点，我必须做一个定制的Sink连接器，将转换后的数据发送到kafka主题，但是，这些接口函数似乎在SinkConnector中不可用。
浏览 11提问于2021-04-26得票数 0
我使用Kafka连接器作为源连接器。该文档提供了一种使用REST API管理的方法。
如果kafka-connector已经启动并运行，并且我们尝试创建一个新的连接器(实例)，那么这是可行的。但是在Kafka Connect worker本身启动期间，如果我们需要在分布式属性文件中传递一些凭据，比如SSL证书密码。是否可以使用kafka- FileConfigPr
浏览 0提问于2020-06-16得票数 0
1回答
我有一个web服务器接收一些事件作为post请求，我想处理使用Kafka流。我可以使用哪个源连接器来实现这一点？
浏览 12提问于2020-10-20得票数 0
我想要从一个系统到另一个系统的实时流。 我正在使用kafka-python，并且能够在本地直播。 计算出连接器将处理多个设备。有人能给我推荐一种在python中使用连接器实现它的方法吗？
浏览 28提问于2021-10-07得票数 1
回答已采纳
我使用的是kafka_2.11.-0.9.0.1。首先，我用以下命令启动了zookeeper & kafka (如所解释的)：然后：bin/kafka-server-start.sh config/server.properties
现在，我正在尝试从REST API (如所解释的)中获取
浏览 0提问于2016-04-27得票数 1
我正在构建一个自定义的Kafka源连接器。此连接器已启动并正在运行。我使用rest API更新连接器配置设置(例如，源端点和连接键)。我使用下面的Rest API PUT /connectors/{name}/config 由于某些问题(例如，错误的密钥)，API不会成功，连接器也会失败 接口输出如下所示。请注意，<
浏览 33提问于2020-04-17得票数 0
1回答
但是，我不能从启动连接，也许是因为我需要提供的安全证书？我已经尝试将引导属性设置为：获取错误:在身份验证期间终止到节点-1 (/xx.xx:9092)的连接。这可能是由于以下任何原因造成的：(1)身份验证失败是由于代理的凭据无效，代理的年龄超过1.0.0；(2)防火墙阻塞Kafka TLS通信量(例如，它可能只允许HTTPS通信)；
浏览 2提问于2020-03-02得票数 1
2回答
我有一个Kafka连接源和接收器连接器，用于将数据放入Kafka中并将其取出来。我正在使用docker-compose运行Kafka和Kafka Connect，它在分布式模式下运行connect。确保在connect启动时它能找到我的插件，但它实际上不会做任何事情，除非我对JSON执行POST操作，包括/connectors中的配置。我有一个包含配置的属性文件，我尝试将它放在/etc下，在那里我找到了与其他已安装
浏览 21提问于2019-02-26得票数 3
回答已采纳
我想使用现成的kafka连接器从REST API获取数据。我在confluent集线器上找到了kafka-connect-http连接器，但是这个连接器不支持API的预认证。
浏览 11提问于2020-08-13得票数 1
回答已采纳
我是第一次接触kafka connect。我在服务器上配置了一个接收器连接器，用于将数据从kafka队列发送到elastic search。我已经创建了一个项目来产生数据到kafka队列。这是成功的，因为当我尝试使用Kafka consumer消费数据时，我可以看到数据。现在，我需要在Java项目中进行哪些配置，以便启动接收器连接器并将数据从Kafka队列转移到elastic search。或者这应该是自动发生的，因为连接器<
浏览 4提问于2021-07-04得票数 0
我在Kafka connect中有一个主题，我想把数据写到两个不同的位置。为此，我有两个自定义连接器。我不是在使用汇合平台，我只是在研究卡夫卡集群，我计划使用卡夫卡的connect-distributed.sh。另外，我应该将每个属性和连接器jar文件放到kafka集群的每个节点上吗？
谢谢。
浏览 0提问于2019-07-28得票数 0
我们使用 Cassandra插件将从Logstash到Apache的事件(日志)输入。我们已经达到了插件的最大吞吐量为8K，因为它只打开到Cassandra的2个连接，而Cassandra的吞吐量要高得多(用于消耗数据)，并且我们预计实际系统的吞吐量为30K或更高。这里的吞吐量是使用传入事件的能力，即x单位/秒。我们正在寻找来自堆栈溢出帖子的
浏览 5提问于2021-07-06得票数 0
回答已采纳
我面临的情况是，多个开发人员正在致力于特定的kafka源或接收器连接器配置。连接器通过创建、更新、删除等。必须保证
开发人员从不删除或修改他人的连接器。开发人员只能管理特定connector.class的连接器，例如connector.class。是否有任何方法来配置Kafka，将Kafka-Connect REST的使用限制在与连接
浏览 10提问于2022-07-22得票数 0
回答已采纳
我有一个使用io.confluent.connect.jdbc.JdbcSourceConnector类的Kafka源连接器。它在incrementing mode中运行。我可以通过Rest interface访问这个连接器。要检查问题，我想知道此连接器的当前递增值。 有没有办法用Rest读取当前递增的值？
浏览 20提问于2021-06-29得票数 0
回答已采纳
2回答
我想使用Kafka Connect REST API运行JDBC源连接器。API运行连接器。电话是这样的：
curl -X POST -H "Content-Type: application/json" --data '{"name": "source-mysql-test", "configAPI来运行JDBC接收器连接器，
浏览 38提问于2018-05-15得票数 6
回答已采纳
2回答
有一项要求，即来自应用程序的数据必须与数据仓库尽可能接近实时地同步(延迟3-5分钟以上的所有内容都是不可接受的，实时复制将是最好的)。Citus是Postgres的扩展，你能把它当作一个普通的Postgres数据库吗？如果是，那么逻辑复制理论上应该工作，但是它如何处理分布式表呢？我是否需要将逻辑级别的WAL流到Kafka中，然后编写自定义逻辑将其转换为目标数据库上的SQL语句？有什么工具吗？额外的问题:是否有人有使用过Citus和Gr
浏览 0提问于2021-02-04得票数 0
我试图使用HTTP连接器作为复制活动中的源链接服务，从Data中的网站下载CSV文件。它基本上是对一个看起来像的url的网络调用。
该网站使用基本身份验证。我在复制活动中使用REST连接器将数据下载为JSON文件(相同的url，只是其中没有".csv“)，这很好。但是，HTTP连接器中的身份验证有一些不同之处，并引发了一些问题。当我尝试执行我的<
浏览 2提问于2020-07-29得票数 1
回答已采纳
云服务器
ICP备案
云直播
实时音视频
即时通信 IM
腾讯云开发者
