我将以下配置添加到源连接器(Debezium MySQL)配置中： "transforms": "route,csFilter", ...因此我下载了jar file并将jar文件(连接转换、连接实用程序、json路径)复制到path-to-kafka/connect/debezium-connector-mysql目录。当我尝试注册Debezium MySQL源连接器时， cu
浏览 123提问于2020-07-15得票数 1
回答已采纳
使用独立模式，我创建了一个连接器，并进行了如下定制的转换：connector.class=com.github.jcustenborder.kafka.connect.rabbitmq.RabbitMQSourceConnectorenvelope.routingKey", }对于最后一个变体，我得到以下<e
浏览 17提问于2017-09-08得票数 1
回答已采纳
2回答
当我使用Confluent Control Center创建源或接收器连接器时，它会将与该连接器相关的设置保存在哪里？是否有我可以浏览的文件？我们正计划创建50+连接器，在某一时刻，我们需要将它们从一个环境复制到另一个环境，我想知道是否有简单的方法来做到这一点。
浏览 1提问于2018-04-27得票数 0
4回答
我正在尝试使用Kafka Connect Elasticsearch连接器，但没有成功。它正因以下错误而崩溃：我已经为kafka子文件夹
浏览 1提问于2018-11-21得票数 9
我需要别人的帮助。这是我的设置和其他信息。卡夫卡连接：。MySQL连接器: 0.8.1决赛。
我添加插件路径
当我试图连接到Kafka Connect时，它给了我一个错误。“未能找到实现连接器且名称与io.debezium.connector.mysql.MySqlConnecto
浏览 2提问于2018-08-14得票数 3
回答已采纳
1回答
这是我的连接器插件这是我的连接器配置 "name": "inventory-connector", "connector.class": "io.debezium.connector.mysql.MySqlConnector": "localhost:9092",
"database.history.kaf
浏览 2提问于2021-06-21得票数 1
任何人都可以帮助我消耗连续数据中的数据，这些数据正在被流式传输。在snowflake连接器中应该为主题提供什么？
因为我能够使用所需的主题名称通过单个表数据填充数据。但我有捕获连续数据流到表中的要求。
浏览 0提问于2021-10-07得票数 5
2回答
我得到的错误是：我用来运行的命令(不包括标准的动物园管理员/ kafka命令)：
/path_to_kafka/kafka_2.12-2.3.0/bin/connect-standa
浏览 6提问于2019-12-13得票数 1
我正在尝试使用camel- sftp - kafka -connector在Apache kafka中创建一个sftp连接器。我刚刚下载了sftp-connector jar并粘贴到了kafka的lib文件夹中。点击/connector-plugins端点时，我可以看到sftp-connector是可用的下面是我的连接器配置示例 "name": "camel-sftp-c
浏览 11提问于2021-05-05得票数 0
我在Kafka connect中有一个主题，我想把数据写到两个不同的位置。为此，我有两个自定义连接器。我不是在使用汇合平台，我只是在研究卡夫卡集群，我计划使用卡夫卡的connect-distributed.sh。另外，我应该将每个属性和连接器jar文件放到kafka集群的每个节点上吗
浏览 0提问于2019-07-28得票数 0
卡夫卡连接开始时(例如在汇合平台)，是否有自动加载(多个) Kafka连接连接器的方法？到目前为止我发现的是：是否还有另一种方法，例如，将所有的连接器都包含在“Connect -独立的\\Distributed.properties”文件中(类似于在KSQL -server.properties中提供ksq
浏览 2提问于2019-06-06得票数 5
我正在使用properties/json文件配置连接器，在从源连接器读取消息时，我尝试添加一个时间戳列，其中包含kafka时间戳，但没有成功。我尝试过添加transforms，但是它总是null，我的接收器连接器“大查询”返回了一个错误
transforms=InsertField$Value
我的源Config Sap
浏览 0提问于2018-11-15得票数 1
回答已采纳
需求:需要将json有效负载从spring引导应用程序发送到google。
我已经开始实施卡夫卡制作人和发布信息的主题，从那里到卡夫卡消费者收到的json。现在，我需要发送json有效负载从卡夫卡消费者到谷歌酒吧/潜艇。我很困惑，我应该为此需要卡夫卡的消费者吗。或者只是从卡夫卡生产者到谷歌酒吧子，我可以发送通过使用卡夫卡connector.jar和配置在主题中的属性。对于此实现，任何帮助都是非常感谢的。
浏览 3提问于2019-03-21得票数 1
回答已采纳
1回答
我们已经将模式注册表和Kafka设置为使用基本身份验证。一些连接器似乎正在运行。但其中有些人犯了一个错误：
我如何将模式注册表的凭据授予Kafka Connect？是在连接器配置中定义它还是在conn
浏览 2提问于2021-12-01得票数 2
回答已采纳
我正在使用Strimzi，Kafka，Kafka Connect和一个自定义连接器插件，遵循。
我知道原因:它找不到插件(一个jar文件)。此外，我运行cat /tmp/
浏览 6提问于2021-12-10得票数 0
回答已采纳
OutOfMemory错误的上下文
所有的后期数据都将在连接
浏览 1提问于2018-06-21得票数 21
回答已采纳
1回答
:65)internal.key.converter=org.apache.kafka.connect.json.JsonConverterinternal.value.converter=org.apache.kafka.connect.json.JsonConverter
internal.value.converter.sch
浏览 6提问于2017-08-10得票数 1
回答已采纳
1回答
我正在尝试为接收器连接器实现一个自定义的写入策略，按照这里的文档，该连接器可以写入mongodb：
package com.fu.connect.sink-1.8.0-confluent.jar,writemodel.strategy=com.fu.connect.sink.CustomWriteModelStr
浏览 13提问于2022-11-08得票数 0
我试图屏蔽连接器的用户名和密码，为此我创建了一个名为"login“的文件来加载这些信息。阅读KIP 并遵循的答案，但我得到了ORA-01017“无效用户名/密码”错误。我认为文件路径有问题，因为我没有完全得到它。我应该如何给出文件路径，准确的位置
或者仅仅是文件
浏览 3提问于2021-11-15得票数 1
回答已采纳
我已经在本地启动了Kafka (2.8.0版)，并且正在运行Connect并得到这个输出。
如何启动Snowflake连接器？Due to constraint configuration problems the provider org.apache.kafka.connect.runtime.rest.resources.RootResourceWARNING: The (sub
浏览 0提问于2021-10-13得票数 1
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
云直播
对象存储
腾讯会议活动推荐
腾讯云开发者
