腾讯云
开发者社区
文档
建议反馈
控制台
登录/注册
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(4849)
视频
沙龙
1
回答
通过
Debezium
将MySQL复制到PostgreSQL时丢失
的
数据类型信息
、
、
、
、
我需要将MySQL
数据库
复制到PostgreSQL
数据库
。我选择了: { "name": "
浏览 1
提问于2022-01-14
得票数 0
回答已采纳
1
回答
Kafka连接:如何处理
数据库
模式/表
更改
、
、
、
想知道是否有关于如何处理
数据库
架构
更改
的
文档化过程。我
使用
Debezium
源
连接器
进行postgres
和
汇流
JDBC
Sink
连接器
复制
数据库
更改
。我需要在
数据库
中
做一些
更改
如下我不知道怎样才是最好
的
办法。我
浏览 3
提问于2022-08-16
得票数 1
4
回答
PostgreSQL -> Oracle复制
、
、
、
我正在寻找一种工具,以导出数据从甲骨文
数据库
到PostgreSQL数据仓库。我真的在寻找一个异构
的
数据库
复制工具,而不是一个导出->转换->导入解决方案。或者我被某种预定
的
pg_dump/SQL*Loader解决方案卡住了?
浏览 6
提问于2009-06-17
得票数 3
回答已采纳
1
回答
在Server上
使用
JDBC
Sink
连接器
自动创建适当
的
日期时间类型字段
、
、
我
使用
Debezium
1.2因此,我设置了MSSQL
源
连接器
和
JDBC
Sink
连接器
。DATETIME列在用户
数据库
中
作为
INT64创建。我在
JDBC
接收器
配置中用这样
的</em
浏览 1
提问于2020-09-27
得票数 2
回答已采纳
1
回答
无法
使用
debezium
作为
源
和
合流
jdbc
接收器
连接器
获取
目标
数据库
中
的
删除
更改
。
、
、
、
、
我
的
Dockerfile,用于下载
接收器
连接器
和
mysql
jdbc
驱动程序 FROM
debezium
/connect ENV KAFKA_CONNECT_
JDBC
_DIR=$KAFKA_CONNECT_PLUGINS_DIR/$KAFKA_
JDBC
_VERSION/kafka-connect-
jdbc
-$KAFKA_
JDBC
_VERSION.jar 我将这个没有扩展名Dockerfi
浏览 34
提问于2020-07-07
得票数 0
回答已采纳
2
回答
如何
使用
JDBC
接收器
连接器
将表名转换为大写
、
、
、
、
我正在实现基于CDC
的
Postgres
和
Oracle
数据库
之间
的
复制。对于
源
连接器
,我
使用
的
是
Debezium
的
Postgres
连接器
和
汇
连接器
--Confluent
的
JDBC
sink
连接器
。在Postgres
数据库
中
,所有表都是用小写创建
的
,但在Orac
浏览 5
提问于2021-04-01
得票数 1
1
回答
没有主键
的
Debezium
或
JDBC
跳过表
、
、
、
、
我在容器中有
Debezium
,捕获PostgeSQL
数据库
记录
的
所有
更改
。此外,还有一个汇合
JDBC
容器可以将所有
更改
写入另一个
数据库
。在
源
连接器
中
,定义允许捕获多个表,因此有些表具有主键,而另一些则没有。在
接收器
连接器
中
,定义指定pk.mode,如下所示:"de
浏览 8
提问于2022-11-01
得票数 0
1
回答
卡夫卡连接-每个
连接器
有多少任务
、
、
正如我从文档
和
其他引用中看到
的
那样,不管通过属性(tasks.num)定义
的
值如何,
连接器
似乎都将被实例化为单个任务。Whether,这个属性,tasks.num会有什么影响,比如在失败
的
情况下等等?例如,如果tasks.num配置为2,而
jdbc
连接器
与单个任务一起
使用
,并且该任务失败而其他任务将接管?在这种情况下分布式模式
的
意义是什么?实际上,
连接器
是用单个任务创建
的
?。
浏览 2
提问于2022-01-15
得票数 0
回答已采纳
2
回答
将PostgreSQL数据复制到基图斯/格林梅利?
、
、
、
、
我需要在数据仓库中集成来自3个不同PostgreSQL
数据库
(OLTP应用程序后端)
的
数据。对于数据仓库本身,我考虑
使用
Citus或Greenplum。有一项要求,即来自应用程序
的
数据必须与数据仓库尽可能接近实时地同步(延迟3-5分钟以上
的
所有内容都是不可接受
的
,实时复制将是最好
的
)。Citus是Postgres
的
扩展,你能把它当作一个普通
的
Postgres
数据库
吗?如果是,那么逻辑复制理论上应该工作,但是它如何处理
浏览 0
提问于2021-02-04
得票数 0
1
回答
如何在rest api
中
添加/
删除
Pulsar
中
的
连接器
?
、
我正在
使用
支持
Debezium
源
连接器
的
Pulsar IO,以便从您
的
数据库
获取
流
更改
。从文档
中
可以清楚地看到如何连接到MYSQL, $ bin/pulsar-admin source localrun --sourceConfigFile
debezium
-mysql-source-config.yaml监视
连接器
的
步骤 bin/pulsa
浏览 10
提问于2019-08-31
得票数 0
2
回答
提取
和
转换
jdbc
接收器
连接器
的
kafka消息特定字段
、
、
、
、
我有一个kafka主题,它
使用
Debezium
mysql
源
连接器
从mysql
数据库
获取
数据,以下是其中一条消息
的
格式: "Message": { }
浏览 7
提问于2020-04-18
得票数 1
1
回答
如何在kafka
jdbc
连接
源
中
过滤
数据库
中
的
表
、
、
、
我正在
使用
Confluent社区平台中
的
Kafka来保持MySQL
数据库
的
同步。
源
和
汇是MySQL
数据库
。它没有起作用。我希望在
源
连接器
和
Sink
连接器
中都
使用
org.apache.kafka.connect.json.JsonConverter,但是
接收器
连接器
无法
正确插入。我想同步几个
数据库
,不同
数
浏览 0
提问于2019-02-19
得票数 0
1
回答
debezium
是否支持捕获postgres模式
更改
事件?
、
、
debezium
是否支持捕获postgres模式
更改
,如“alter table xxx add/drop/alter column xxx”?
浏览 5
提问于2019-12-14
得票数 0
1
回答
如何
使用
postgres
JDBC
接收器
连接器
流到mysql
连接器
、
、
、
、
我一直在尝试在
Debezium
中
创建一个
连接器
Postgres
连接器
,但只有当表已经存在于我
的
MySQL实例(这并不理想)时,我才能捕获
更改
。因为那样的话,我将不得不用Python编写一个脚本来处理这样
的
事件,而且
使用
已经存在
的
东西可能比重新发明轮子更容易。我希望能够在实际
连接器
中
捕获DDL。我偶然看到这篇博文。和我让它在我
的
本地设置上工作,这是很棒
的
,但唯一<e
浏览 6
提问于2022-07-21
得票数 0
回答已采纳
1
回答
如何用
debezium
捕获mysql
中
的
数据,在kafka连接
中
改变数据捕获
和
使用
jdbc
接收器
?
、
、
、
我在用
debezium
捕获mysql
中
的
数据时遇到了问题,将数据捕获并
使用
kafka连接
jdbc
接收器
将其消费到另一个mysql。因为
debezium
对kafka主题产生
的
模式
和
有效负载与kafka连接
jdbc
接收器
所期望
的
模式不兼容。 当
jdbc
接收器
想要
使用
数据并在另一个mysql
中
创建记录时,我就会异常。
浏览 2
提问于2017-05-14
得票数 1
回答已采纳
1
回答
卡夫卡连接
Debezium
MySQL
连接器
时间戳发行
、
、
、
、
我
使用
部署在Kafka
中
的
Debezium
MySQL
连接器
来流MySQL对Kafka
的
更改
,我们从那里
获取
这些消息,丰富数据并将数据推送到另一个MySQL。
源
和
汇都是MySQL。(
数据库
,MySQL)
中
时,将在上面的字符串
中
遇到T
和
Z
的
问题,在
目标
数据库
中
,数据类型也是时
浏览 13
提问于2021-12-22
得票数 0
1
回答
Debezium
:从MySQL
中
删除
的
数据在弹性搜索
中
重新出现
、
、
、
、
我
使用
过
Debezium
作为
Mysql
的
-> Elasticsearch。现在
的
问题是,当我从MySQL
中
删除
数据时,它仍然会在Elasticsearch
中
重新出现,即使数据不再存在于MySQL DB
中
。UPDATE
和
INSERT工作正常,但DELETE不是。另外,我做了以下工作:Delete Elasticsearch索引
和</e
浏览 7
提问于2021-03-14
得票数 0
1
回答
无法
将KSQL聚合表持久化到Postgres
、
、
我试图
使用
JDBC
接收器
连接器
在Postgres
中
镜像一个KSQL表,但不幸
的
是,我
无法
使它工作。', KEY='id'); 此时,一切都正常,我可以处理流
和
表,并加入,并看到我
的
源
DB
中
的
更改
立即反映在KSQL
中
的
流查询
中
。当我决定对数据执行一些聚合函数并在Postgres (与
浏览 9
提问于2020-03-24
得票数 1
回答已采纳
1
回答
汇流
JDBC
Sink
连接器
无法
识别
debezium
连接器
捕获
的
记录
、
、
、
debezium
连接器
捕获postgresql 13数据,然后生成到kafka。并且我将汇合
的
JDBC
接收器
连接器
附加到kafka
的
另一边,但是它没有正确地识别json消息。经测试
的
环境: 接口/kafka-
连接器
-
jdbc
在github
浏览 18
提问于2022-05-30
得票数 0
回答已采纳
2
回答
将数据从kafka复制到mysql,不能用DOcker
和
Debezium
连接到DOcker。
、
、
嗨,我正在
使用
debezium
捕获Mongo
中
的
更改
并将它们推入mysql --我
使用
下面的链接将end替换为mysql
数据库
,但我
无法
这样做。这是我修改过
的
jdbc
-sink.json,在这里我
使用
mysql url进行连接。,error_code”:500,“message”:“未能找到任何实现
连接器
且名称与io.
debezium
.connector.mong
浏览 0
提问于2019-11-06
得票数 0
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
CDC Debezium 介绍
Flink CDC 的实现原理是什么?
Flink CDC 如何捕获数据库中的数据变化?
这可能是北半球最暖的Kafka Connect数据管道教程:3
Flink 支持哪些数据源和数据接收器?
热门
标签
更多标签
云服务器
ICP备案
对象存储
腾讯会议
云直播
活动推荐
运营活动
广告
关闭
领券