Apache Kafka Connect是Apache Kafka与其他数据系统之间可扩展且可靠的流数据的工具。 - https://kafka.apache.org/documentation.html#connect
Confluence MySQL Sink Connector 的开源替代方案？
Confluence 的 MySQL 接收器连接器有其他选择吗？
如何使用ssl postgres身份验证为postgresql配置kafka connect jdbc接收器连接器？
我有一个使用用户名和密码配置的 postgres 工作 jdbc 接收器连接器配置： { “connector.class”：“io.confluence.connect.jdbc.JdbcSinkConnector”...
如何通过JDBC连接器将oracle中的日期类型列转换为kafka主题上的int类型
我正在尝试使用 JDBC 连接器将数据从一个或 Oracle 表提取到 kafka 主题。在我的源表中，有一个字段 - test_date 是“日期”数据类型。样本值在此
我的 debezium 和 kafka 集成面临“不支持的源数据类型：STRUCT”错误
我在将 debezium 和 kafka 与 Oracle RDBMS 集成时遇到以下错误： org.apache.kafka.connect.errors.ConnectException：由于不可恢复的异常而退出 WorkerSinkTask。 钙...
在 Kafka Connect Struct Schema 上设置默认值
我似乎在这里遗漏了一些明显的东西，或者 Kafka Connect 严重损坏，这似乎不太可能。 我正在尝试在 Kafka Connect 的结构类型模式上设置默认值。第一个...
我正在尝试实现雪花卡夫卡连接器以将数据实时摄取到雪花中。个人系统上的 Kafka 设置已完成，我可以实时推送事件和订阅事件
安装 kafka 连接器时出现 ConfluenceHubClient 异常
我已经设置了 Kafka 集群并在 EC2 实例上安装了 confluence-hub。我已经下载了 confluence-hub tar 文件，解压并将二进制文件放入 /usr/local/bin 中。 当我现在尝试
我正在使用confluence kafka jdbc连接器（https://github.com/confluenceinc/kafka-connect-jdbc），但我没有找到/etc/kafka/connect-log4j.properties文件，该文件是描述于 https://docs.confl...
如何重置 Apache Kafka-Connect 服务器中的源连接器偏移量
从 Kafka 连接中删除源连接器后，该连接器保存的偏移量仍然存在于 Kafka 中。 当具有相同名称的相同连接器再次启动时，它会开始
我正在使用kafka的docker镜像和kafka连接使用debezium测试cdc，并且数据库是独立的 我的接收器连接器配置 json 看起来像这样， { “姓名”：“...
如何配置Confluence Platform Kafka jdbc连接日志？
我正在使用confluence kafka jdbc连接器（https://github.com/confluenceinc/kafka-connect-jdbc），但我没有找到/etc/kafka/connect-log4j.properties文件，该文件是描述于 https://docs.confl...
有没有办法将Amazon MSK Topic直接转储到S3？
我计划使用 Amazon MSK 并且我想将消费者日志转储到 S3 。但我没有看到任何选择。我是否需要编写自己的消费者，或者有没有办法将 Amazon MSK 消费者输出消费到...
无法通过引用链从 START_OBJECT 反序列化 `java.lang.String` 实例：java.util.LinkedHashMap[\"key.schema\"
嗨，两周以来我一直遇到一个问题，我正在尝试使用 CSV 源连接器在 kafka 分区中上传 CSV。首先，我在 Windows 11 上尝试使用first.row.as.header:true, Source
如何使用 Debezium 处理 OracleDB 中经典的空字符串转换为 NULL
我正在使用 Kafka 集群，该集群将 MySQL 数据库中包含的数据复制到旧的 Oracle 数据库，以实现我已将源数据库连接到 Debezium Mysql 连接器和接收器数据库...
是否可以在jdbc连接器中将多个表中的数据读取到单个主题中？ 我读过有关相同内容的某些文章，发现可以使用 ksql db 或数据流来完成，但可以......
无法在 Windows 11 中使用 SpoolDirCsvSourceConnector 创建用于 CSV 到 Kafka 的 kafka 连接源和接收器连接器
我想使用此存储库将我的 testdata.csv 上传到 Kafka 主题。现在，curl 命令无法创建自定义连接器curl -i -X PUT -H "Accept:application/json" -H "Conten...
我正在使用 Kafka Connect 接收器连接器从 Kafka 读取事件并将其插入数据库。 某些事件在其值负载中包含引用。我想使用 SMT 来解决这些问题...
我按以下方式设置kafka neo4j接收器连接器： 创建 /tmp/plugins，下载 neo4j-kafka-connect-neo4j-5.0.2.zip 并解压到插件文件夹中，即 修改connect-standalone.properti...
我是Kafka Connect的新手，我不知道kafka分区和kafka connect分区之间的区别。它们是同一个概念吗？如果不是同一个概念，它们之间有什么关系...
Kafka - Elastic Sink - 小数/日期值的 AVRO 架构数据转换问题
我们看到一个问题，即弹性端上的小数和日期数据未正确填充...下面是整个上下文，任何人都可以输入，我们将不胜感激。谢谢 对于班级：“io.