我正在尝试使用https://github.com/llofberg/kafka-connect-rest上的社区贡献连接器来轮询来自HTTPs REST端点的数据。我的连接器的配置是as。": "com.tm.kafka.connect.rest.converter.
浏览 33提问于2020-03-21得票数 0
我需要为REST API创建kafka源连接器与头部身份验证，如curl -H "Authorization: Basic“-H "clientID：”"https:< url for source>我使用的是apache kafka，我使用的是连接器类com.github.castorm.kafka.connect.http.HttpSo
浏览 14提问于2020-09-06得票数 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 Connect是否支持枚举字段？如果不是，通常的解决方法是什么？我在这里查看的是Kafka 2.6.0API：https://kafka.apache.org/26/javadoc/org/apache/kafka/connect/data/ConnectSchema.h
浏览 29提问于2020-10-01得票数 0
我想使用现成的kafka连接器从REST API获取数据。我在confluent集线器上找到了kafka-connect-http连接器，但是这个连接器不支持API的预认证。
浏览 11提问于2020-08-13得票数 1
回答已采纳
卡夫卡流是好的，但我必须做每一个配置非常手动。相反，Kafka提供了它的API接口，它对于处理配置以及任务、工作人员等都非常有用。
因此，我正在考虑在我的简单数据转换服务中使用Kafka。基本上，服务将从一个主题读取数据，并将转换后的数据发送到另一个主题。为了做到这一点，我必须做一个定制的Sink连接器，将转换后的数据发送到kafka主题，但是，这些接口函数似乎在SinkConnector中不可用。
浏览 11提问于2021-04-26得票数 0
我使用Kafka连接器作为源连接器。该文档提供了一种使用REST API管理的方法。
如果kafka-connector已经启动并运行，并且我们尝试创建一个新的连接器(实例)，那么这是可行的。但是在Kafka Connect worker本身启动期间，如果我们需要在分布式属性文件中传递一些凭据，比如SSL证书密码。是否可以使用kafka<
浏览 0提问于2020-06-16得票数 0
我们使用 Cassandra插件将从Logstash到Apache的事件(日志)输入。我们已经达到了插件的最大吞吐量为8K，因为它只打开到Cassandra的2个连接，而Cassandra的吞吐量要高得多(用于消耗数据)，并且我们预计实际系统的吞吐量为30K或更高。这里的吞吐量是使用传入事件的能力，即x单位/秒。我们正在寻找来自堆栈溢出帖子的
浏览 5提问于2021-07-06得票数 0
回答已采纳
2回答
我有一个Kafka连接源和接收器连接器，用于将数据放入Kafka中并将其取出来。我正在使用docker-compose运行Kafka和Kafka Connect，它在分布式模式下运行connect。确保在connect启动时它能找到我的插件，但它实际上不会做任何事情，除非我对JSON执行POST操作，包括/connectors中的配置。我有一个包含配置的属性文件，我尝试将
浏览 21提问于2019-02-26得票数 3
回答已采纳
我正在构建一个自定义的Kafka源连接器。此连接器已启动并正在运行。我使用rest API更新连接器配置设置(例如，源端点和连接键)。我使用下面的Rest API PUT /connectors/{name}/config 由于某些问题(例如，错误的密钥)，API不会成功，连接器也会失败 接口输出如下所示。请注意，<
浏览 33提问于2020-04-17得票数 0
使用合流社区包在DC/OS上运行Kafka 4.1.1。我们如何上传或添加jdbc驱动程序到远程集群？
更新:它是一个安装了DC/OS目录的包，它是一个mesos框架，运行的是docker映像。
浏览 1提问于2018-11-11得票数 1
我正在阅读关于Kafka和Kafka Connect的文章。文档在Kafka Connect文档中以一种通用的方式提到了“Kafka源”和“Kafka汇”。我不确定这两个术语是否特定于Kafka Connect，或者它们只是指生产者和消费者。
浏览 13提问于2021-06-24得票数 0
回答已采纳
在端口8083上，我运行的是Influxdb，我甚至可以在上获得图形用户界面现在使用"kafka connect“的连接器配置来工作：bin/connect-standalone
浏览 173提问于2018-06-05得票数 4
回答已采纳
使用ksqlDB，我已经创建了一个带有自定义查询的JDBC连接器。然后，根据生成的kafka主题，我创建了一个表。但是，从表中选择只返回主键的数据，而返回所有其他值的null。我正在连接的postgres数据库的sales表不断更新新数据，我正尝试使用ksql流式传输这些数据。ksql> CREATE SOURCE CONNECTOR con WITH (
'connector.class' =
浏览 27提问于2020-11-30得票数 0
回答已采纳
Kafka Connect的REST API未经过安全和身份验证。由于它未经过身份验证，因此任何人都可以轻松访问连接器或任务的配置。由于这些配置可能包含在SourceConnector情况下如何访问源系统，在SinkConnector情况下如何访问目标系统，是否有标准方法来限制对这些API的访问？
浏览 0提问于2017-07-22得票数 10
1回答
我已经设置了Kafka JDBC接收器连接器，在那里它将使用来自kafka生产者api的数据，但是我想设置FME来处理数据端，并将其接收到数据库，在那里它将与GIS (地理信息系统)交互，它将流式传输空间数据我对FME了解不多，是否有任何信息/文档，或者是否有人知道并可以解释如何使用Kafka JDBC Sink Connector设置FME谢谢
浏览 16提问于2021-02-02得票数 0
如何删除debezium连接器。我正在学习本教程https://debezium.io/documentation/reference/tutorial.html，我看到了注册连接器的方法，但不知道如何删除/更新连接器。184054", "database.server.name": "dbserver1", "database.include.list": "inv
浏览 193提问于2021-06-24得票数 0
回答已采纳
我面临的情况是，多个开发人员正在致力于特定的kafka源或接收器连接器配置。连接器通过创建、更新、删除等。必须保证
开发人员从不删除或修改他人的连接器。开发人员只能管理特定connector.class的连接器，例如connector.class。是否有任何方法来配置Kafka，将Kafka-Connect REST
浏览 10提问于2022-07-22得票数 0
回答已采纳
云服务器
ICP备案
云直播
即时通信 IM
实时音视频
腾讯云开发者
