如何使 Confluence sftp 连接器重复处理 csv 文件
美好的一天， 我正在尝试点击 Confluence sftp 连接器的链接： https://docs.confluence.io/kafka- connect-sftp/current/source-connector/index.htm…
confluence 5.0.1 升级到 7.0.1
尝试升级融合我检查了升级链接： https://docs.confluence.io/platform/7.0.1/安装/升级.html 我发现里面的准备部分说： - If you’re running a Conf…
Confluence 平台与 Debezium 对比
我正在尝试使用 Debezium 平台制作 Kafka-cdc。但我很困惑。 Confluence 平台和 Debezium 之间的真正区别是什么？…
JDBC Sink Connector 与 Redshift Sink Connector 之间的区别
我是 Kafka 新手，我想知道为什么有特定的数据库连接器（例如 Redshift Sink Connector）以及为什么我们不应该使用通用 JDBC 接收器连接器。两者有什…
ksqlDB java 客户端：无法从 client.executeStatement() 反序列化数据
我正在尝试使用 Java ksqlDb-api-client:0.24.0 使用下面的代码查询汇合云上的 KSQL 流 ClientOptions options = ClientOptions.create() .setHost(KS…
尝试使用 Docker 通过 jar 文件安装 Kafka Connect 连接器，安装出现错误
我正在使用 docker-compose 和 Dockerfile 来安装连接器。我已成功从 Confluence Hub 安装连接器，但未能成功安装我自己的 jar 文件。 这就是我所做的…
Kafka jdbc接收器连接器创建与原始数据类型不匹配的数据类型
我正在使用 Kafka 和 Kafka Connect 将 MS SQL Server 数据库复制到 MySQL，使用 debezium sql server CDC 源连接器和汇合 JDBC 接收器连接器。 “aut…
从缓存中重新填充 _schemas 主题
几天前，我们丢失了 kafka 代理上的所有数据，以及架构注册表使用的内部 _schemas 主题中的所有消息。 不过，模式注册表节点仍然启动并运行，因此我们…
