腾讯云
开发者社区
文档
建议反馈
控制台
首页
学习
活动
专区
工具
TVP
最新优惠活动
文章/答案/技术大牛
搜索
搜索
关闭
发布
登录/注册
精选内容/技术社群/优惠产品,
尽在小程序
立即前往
文章
问答
(9999+)
视频
沙龙
1
回答
如何增加
debezium
连接程序的tasks.max?
、
、
我尝试为属性‘
MySQL
’设置
debezium
MySQL
连接器
的配置我
使用
MSK
连接器
与
debezium
自定义插件和
Debezium
版本1.8。
浏览 9
提问于2022-03-15
得票数 0
回答已采纳
1
回答
在
MSK
中
使用
Debezium
MySQL
连接器
显示
"
INVALID_REPLICATION_FACTOR
“
、
、
我
使用
的是带有
MSK
的
Debezium
MySQL
,设置非常简单。与极光(
MySQL
)的连接测试正常。Kafka主题创建,列表都可以。然而,当我运行
连接器
时,
在
滚动了大量信息之后,我得到了 WARN [Producer clientId=xxx] Error while fetching metadata with correlationid 1 : {xxx.xxx=INVALID_REP LICATION_FACTOR} (org.apache.kafka.cl
浏览 252
提问于2021-05-02
得票数 1
回答已采纳
2
回答
如何
使用
用户名和密码从
Debezium
连接器
连接AWS
MSK
、
、
这里,我试图
使用
Debezium
连接器
读取RDS
中
的数据,并将其发布到AWS。我所能看到的就是在任何地方都
使用
基于AWS的身份验证,但不幸的是,我的云工程团队不愿意添加IAM,而是提供了一个要发布的主题(用户名和密码)。我计划
使用
debezium
/connect映像,以便将其部署到EKS。 有没有用用户名和密码连接到
MSK
的方法?
浏览 7
提问于2021-10-19
得票数 0
1
回答
Debezium
CDC
连接器
任务出现错误: javax.management.InstanceAlreadyExistsException
、
、
、
我让我的
debezium
mysql
源
连接器
在
Kafka上工作。我
使用
相同的数据库添加了另一个
debezium
mysql
源
连接器
,但具有不同的数据格式。结果,我的第一个
连接器
开始
显示
以下错误:at io.
debeziu
浏览 274
提问于2019-07-11
得票数 0
1
回答
在
Debezium
Mysql
连接器
中
白化更多表的有效方法
、
、
、
对于将新表白化到
debezium
mysql
连接器
,有什么最佳实践可遵循吗?{ "class": "io.
debezium
.connector.
mysql
.My
浏览 1
提问于2020-05-28
得票数 2
回答已采纳
1
回答
AWS
MSK
- AWS RDS的
Debezium
Postgres
连接器
-连接失败
、
、
当
使用
AWS
MSK
连接器
(
Debezium
Postgres
连接器
)时,我目前面临以下问题 0509fac07b9701a23错误测试jdbc:postgresql://
debezium
-cdc.fac07b9701a2.ap-south-1.rds.amazonaws.com:5432/ecommerce与用户“
debezium
”(io.
debezium
.connector.postgresql.PostgresCon
浏览 11
提问于2022-01-19
得票数 0
1
回答
Debezium
连接器
无法连接到MariaDB,错误'LOAD DATA LOCAL INFILE at is disabled at client‘
、
我们
使用
Debezium
和Kafka-Connect从几个MariaDB数据库实例
中
获取数据。对于大多数数据库,
连接器
都能成功运行,但有一个数据库的
连接器
会失败,并
显示
以下错误: at io.
debezium
.connector.
mysql
.Abstr
浏览 0
提问于2021-01-12
得票数 0
2
回答
亚马逊网络服务: PostgreSQL与Kinesis集成的正确方式是什么?
、
、
、
、
我见过一些人们尝试
使用
Postgresql triggers向Kinesis发送数据的例子。 有些人
使用
wal2json概念。因此,我对选择哪个选项有一些疑问,这就是我寻求建议的原因。
浏览 28
提问于2020-12-10
得票数 1
1
回答
汇合运算符添加其他
连接器
、
、
、
我
在
OpenShift上设置了confluent operator,但此图像'confluentinc/cp-int-container-operator:6.1.0.0‘不包括所有
连接器
。如何在yaml
中
包含任何额外的
连接器
,例如我需要包含用于
mysql
的
Debezium
connect。confluent-hub install
debezium
/
debezium
-connector-
mysql
:1.
浏览 12
提问于2021-08-07
得票数 0
1
回答
用于RDS Aurora的
Debezium
连接器
、
、
、
我正在尝试
使用
debezium
和rds/极光/,我
在
考虑
使用
MySQL
连接器
还是有另一个
连接器
用于Aurora?另外,如何将
debezium
连接器
(Localhost)连接到远程aws极光db?另外,是有人
使用
debezium
与极光分享一些信息。问候
浏览 1
提问于2019-08-28
得票数 3
1
回答
删除"table.include.list“并不强制
Debezium
为数据库
中
的其余表创建主题。
、
、
我创建了
Debezium
连接器
,它的工作原理就像一个魅力: "name": "
debezium
_title", "connector.class奇怪的是,它只为我
在
"table.include.list"
中
为第一个
连接器
设置的表创建了主题!kafka-topics --list --zookeeper xxx.xxx:2181
m
浏览 1
提问于2021-04-23
得票数 1
2
回答
Debezium
MySQL
连接器
-
MySQL
、
、
、
Debezium
mysql
连接器
在
快照的最后阶段失败。这个项目是
在
maven/quarkus上进行的,我想
使用
debezium
/无穷大容量来实现缓存失效。blc-localhost:3306“java.lang.NoSuchMethodError: java.lang.NoSuchMethodError:java.lang.NoSuchMethodError
中
没有记录新的偏移量
在
io.
debezium</
浏览 33
提问于2021-12-09
得票数 0
1
回答
mysql
-
连接器
不能释放全局读锁
、
debezium
-
连接器
-
mysql
,
debezium
核和
debezium
嵌入式.我
在
我的java应用程序中
使用
了这些
debezium
插件。
浏览 2
提问于2017-11-20
得票数 0
1
回答
如何用开放源码的kafka连接从Aurora连接
MSK
、
、
、
、
我必须把我的CDC更改从Aurora
mysql
db到
MSK
主题。我认为
在
aws
中
没有像DMS这样的内置机制,它将使从Aurora到
MSK
主题的所有CDC崩溃,并且在他们的文档
中
,他们没有提到对此的任何支持。 所以我只剩下
使用
开源的东西了。--我也看到了
debezium
one,它将
mysql
连接到
MSK
。Aurora记录将是文本,我需要将记录作为JSON放在
MSK
中
,所以我必须
浏览 2
提问于2019-12-31
得票数 0
回答已采纳
1
回答
如何在rest api
中
添加/删除Pulsar
中
的
连接器
?
、
我正在
使用
支持
Debezium
源
连接器
的Pulsar IO,以便从您的数据库获取流更改。从文档
中
可以清楚地看到如何连接到
MYSQL
, $ bin/pulsar-admin source localrun --sourceConfigFile
debezium
-
mysql
-source-config.yaml监视
连接器
的步骤 bin/pulsar-admin functions getstatus \ --tenant &l
浏览 10
提问于2019-08-31
得票数 0
1
回答
在
一个位置管理两个关系数据库
中
的数据
、
、
、
需要运行涉及两个数据库
中
的表的临时查询。目前,我们正以两种方式之一这样做:
在
我们的邮政服务器上。我们已经
使用
了Google平台(用于
使用
Postgres服务器的项目)。我们熟悉Google BigQuery (BQ)。我们想要做的事情:--我们希望这两个数据库
中
的大多数表(按原样)都可以
在
一个位置上
使用
,所以查询它们是简单而快捷的。我们正在考虑将两个DB服务器上的数据复制到BQ
中
,
浏览 5
提问于2017-03-06
得票数 1
回答已采纳
1
回答
使用
AWS
MSK
NOT_ENOUGH_REPLICAS的
Debezium
、
、
、
我
在
AWS中有一个正在运行的
debezium
集群,没有问题。我想尝试一下AWS
MSK
。所以我启动了一个集群。然后我启动了一个EC2来运行我的
连接器
。没有模式注册表,所以我
在
连接器
EC2模式注册表conf文件
中
对其进行了配置: kafkastore.connection.url=z-1.bhuvi-XXXXXXXXX.amazonaws.com:2181: confluent-hub install
debezium
/
debezium
浏览 128
提问于2019-12-20
得票数 7
回答已采纳
1
回答
过滤数据库
中
的行
、
、
一旦被Kafka摄取,我想根据条件来筛选表
中
的行。 我认为
使用
Kafka streams很容易做到这一点,但是被过滤器拒绝的消息会发生什么呢?
浏览 9
提问于2017-08-11
得票数 0
回答已采纳
1
回答
通过
Debezium
复制
mysql
:缺少表
、
我
在
MySQL
database中有三个表table2和
Debezium
MySQL
连接器
: "name": "
debezium
_
mysql
_1","config": { "connector.class": "io.
debezium
.connector.
mysql
.MySqlConne
浏览 1
提问于2021-05-26
得票数 0
1
回答
在
Confluent Connect
中
创建
连接器
时获取NoClassDefFoundError: org/apache/kafka/connect/header/ConnectHeaders
、
、
、
我
使用
此页面上的说明
在
CentOS 7.9上安装了confluent平台。sudo yum install confluent-platform-oss-2.11 我
使用
的是带有apache版本2.6.1的AWS
MSK
集群。我开始
使用
/usr/bin/connect-distributed /etc/kafka/connect-distributed.properties连接。我已经
在
distributed.propertie
浏览 72
提问于2021-09-16
得票数 0
回答已采纳
点击加载更多
扫码
添加站长 进交流群
领取专属
10元无门槛券
手把手带您无忧上云
相关
资讯
CDC Debezium 介绍
Flink CDC 的实现原理是什么?
Flink CDC 支持哪些数据库?
Flink CDC 如何捕获数据库中的数据变化?
Debezium和Quarkus:通过CDC模式来避免双重写入
热门
标签
更多标签
云服务器
ICP备案
实时音视频
即时通信 IM
对象存储
活动推荐
运营活动
广告
关闭
领券