apache-kafka-connect 相关问题

Kafka Connect Sink JsonConverter DataException：由于序列化错误，将 byte[] 转换为 Kafka Connect 数据失败

为一个项目创建了一个 Apache Kafka 集群（目前有 3 个代理、3 个控制器、1 个工作线程），并且有多个主题从第三方接收数据。工作人员正在利用融合的弹性...

基于查询的 JDBC 源连接器 Kafka

我有一个遗留数据库，它的主键列是字符串（是的，我知道）。我想使用 JDBC kafka Source Connecto 从 postgres DB 到 kafka 主题进行增量转储模式...

Kafka createTopics 失败

我是 Kafka 新手，我正在尝试使用命令行创建一个主题，但出现以下错误： C:\kafka in\windows>kafka-topics.bat --create --topictutorialspedia --boot...

Strimzi 将容器加载到 aws ecr - 检查推送权限时出错

我通过 Strimzi 运算符在 Kubernetes 上运行 Apache Kafka。 我正在尝试使用 mysql debezium 连接器安装 Kafka Connect。 这是连接器配置文件： api版本：kafka.strimzi...

kafka connect 不加载连接器

我正在使用以下 dockerfile 在我的 kafka-connect 映像中加载 mysql 连接器。 来自 eclipse-temurin 运行 mkdir -p /opt/kafka/bin /opt/kafka/libs /opt/kafka/config /opt/kafka/logs 复制./kafk...

如何在从 kafka-snowflake 接收器连接器连接时禁用雪花 OCSP 验证

我们正在尝试使用接收器连接器将数据从kafka主题推送到雪花。但我们无法创建连接器并看到以下警告 严重：警告！！！使用故障打开进行连接。

Kafka 源连接器编码问题 | Oracle JDBC 连接器

我正在尝试使用 Kafka connect JDBC 连接器连接到 Oracle 服务器，这是我的连接器配置： 创建源连接器 hsr_source_connector2 和 （ 'connection.url' = 'jdbc:oracle:thin:@//

如何在连接器级别设置转换器属性？

我需要使用以下属性： value.converter.ignore.default.for.nullables=true 在我的设置中，正如此处提到的那样。 当我将其设置为环境变量时，一切正常：

Jdbc.sink.error 发生意外错误：java.lang.NoClassDefFoundError：无法初始化类 io.confluence.connect.jdbc.sink.JdbcSinkConfig

Confluence 平台添加接收器连接器图像 尝试在汇合平台中添加接收器连接器会给我错误 手动安装连接器 -- confluence-hub install confluenceinc/kafka-connect-jdbc...

表白名单选项的 Confluence JDBC 源连接器问题

我们正在使用 Confluence Kafka JDBC 源连接器从 AWS RDS（Oracle db）获取数据。该连接器适用于 select * from 表名称，但不适用于表白名单选项。它是

Strimzi / Kafka Connect 找不到我的插件

我正在使用 Strimzi、Kafka、Kafka Connect 和自定义连接器插件，遵循此文档。 部署工作正常，Kafka Connect 正在工作，我可以使用它的 RESTFUL API。 但连接器不是

如何在 Kafka 连接中将微秒时间戳转换为毫秒？

使用 confluenceinc/kafka-connect-bigquery 从 Kafka 填充 BigQuery 时，我想使用域 (Avro) 事件的时间戳来（日）对表进行分区。 我的连接器属性...

Debezium 源连接器，向 `after` 对象添加一个字段

我正在 Kafka 中使用 Debezium PostgreSQL 源连接器进行 CDC。下面是我想要推送到 Kafka 的所需消息模式。最值得注意的是 after.source 字段。 after.source 字段...

如何使用java代码使用Kafka连接器？

目前我正在独立模式下使用 Kafka SpoolDir 连接器。将所需的配置添加到属性文件后，我使用以下命令启动连接器 kafka/bin/connect-standalone.sh 连接-

找不到任何实现Connector且名称与MySQL匹配的类

使用官方文档配置kafka connect后... 我收到一个错误，说明 kafka 连接中不存在驱动程序！ 我必须尝试将 .jar 复制到提到的目录中，...

对于具有相似数据和工作负载的主题使用两个 Kafka Connect Sink 连接器有什么优势？

我有两个 Kafka 主题（topic_A 和 topic_B），具有相同的分区（4 个分区）和相似的数据结构。两个主题都需要相同的处理工作。 目前，我正在考虑单身

Neo4j 源连接器无法构建源查询对某些字段返回 null 的架构

我正在使用 Neo4j Source Connector for Kafka (https://neo4j.com/docs/kafka/kafka-connect/source/) 来生成对 Kafka 主题的更改。我的配置如下： { “连接器.class”...

使用自定义[“org.apache.kafka.common.config.provider”]管理Vault Secret的生命周期

我的问题涉及“org.apache.kafka.common.config.provider”接口。如文档中所示： https://kafka.apache.org/35/javadoc/org/apache/kafka/common/config/provider/

Kafka Connect：获取连接器配置

我一直在用kafka connect进行测试。但对于每个连接器，我都必须去阅读连接器文档，以了解连接器所需的配置。据我读过卡夫卡

Kafka 服务器无法运行，同时不会尝试使用 SSAL 进行身份验证（未知错误）

我的卡夫卡服务器有问题。 我已经用端口2080运行apache druid，用端口2181运行zookeeper kafka，以避免破坏druid和kakfa之间的zookeeper。 我没有...