如何有条件地从 Kafka 主题轮询消息
我在 MongoDB 数据库中有一些任务通知。每个任务都有一个 due_date 和提醒标志。我正在将这些任务推送到 Kafka 主题。有一个 Node JS 应用程序从该主…
尝试使用 Docker 通过 jar 文件安装 Kafka Connect 连接器，安装出现错误
我正在使用 docker-compose 和 Dockerfile 来安装连接器。我已成功从 Confluence Hub 安装连接器，但未能成功安装我自己的 jar 文件。 这就是我所做的…
无法打印来自kafka消费者的数据（基于日志的变更数据捕获项目）
我有一个项目，使用kafka、zookeeper、debezium从mysql数据库捕获数据更改。实际上，我对kafka很陌生，我只是遵循debezium教程，所以在尝试使用kafka-…
Kafka Connect 服务失败且没有任何日志
我使用 Kafka 连接与 Kafka bin 版本 2.7.0， 连接服务以独立模式运行并配置了 SSL， 由于内存不足问题（导致我们增加分配的内存）导致服务失败后，Ka…
Kafka jdbc接收器连接器创建与原始数据类型不匹配的数据类型
我正在使用 Kafka 和 Kafka Connect 将 MS SQL Server 数据库复制到 MySQL，使用 debezium sql server CDC 源连接器和汇合 JDBC 接收器连接器。 “aut…
Strimzi KafkaConnect &连接器错误，无法加载
我不知道还能去哪里，因为我看到的所有例子我都复制了很多，但仍然无法让它工作。连接器将不会安装并显示空密码。我已经验证了每一步，但无法使其发挥…
使用 Kafka TimestampConverter 微秒？
我是 Kafka/Avro 的新手。我的下游数据库 (Postgres) 有一个 timestamptz 列。我的上游数据库 (Materialize) 为该列生成以下 Avro 模式： "type": [ "…
Kafka 主题 Avro 键未从 Cassandra 源连接器填充
我有一个 Kafka 主题，它具有以下 Avro Key Schema： { "type": "record", "name": "onboardingStatusKey", "namespace": "onboarding", "fields": [ …
如何处理 Javascript 中的日期格式？
我在弄清楚 js 中重新格式化/转换日期字段的正确方法时遇到问题。 我正在尝试使用 Kafka ODF 流送器和接收器连接器以及中间的 js 创建一个报告来处理…
{“error_code”：500，“message”：“意外字符（“n”（代码110））：需要双引号
我正在执行以下命令，但在 JSON 格式上遇到错误 PS C:\Program Files\PostgreSQL\12\bin> curl.exe -i -X POST -H "Accept:application/json" -H "Con…
连接器配置无效并包含以下 1 个错误：Postgres 服务器 wal_level 属性必须为“逻辑”但是是：复制品 你可以
我正在尝试使用 Debezium Postgres Connector 使用以下命令启动 Kafka Connect 服务： bin/connect-standalone.sh config/connect-standalone.propert…
- 共 1 页
- 1
