Debezium MySQL错误:连接密码为空

文章/答案/技术大牛

发布

2回答

apache-kafka、apache-kafka-connect、debezium

对于我的Debezium连接器，我有以下docker-compose.yml配置： version: '3.1' image::8083/connectors/ -d '{ "name": "mystore-connector", "config": { "connector.class": "io.debezium.connect

浏览 85提问于2019-03-08得票数 0

1回答

无法通过“显示主状态”读取binlog文件名和位置

mysql、docker-compose、debezium

我正在使用debezium版本0.9制作一些POC，并使用嵌入式Debezium配置运行一个标准端口化的mysql数据库。Make sure your server is correctly configured 我怀疑这是因为mysql的独立配置或嵌入式配置，但不确定如何进行和修复。有什么暗示吗？

浏览 0提问于2019-09-24得票数 4

1回答

如何增加debezium连接程序的tasks.max？

apache-kafka、apache-kafka-connect、debezium

我尝试为属性‘MySQL’设置debezium MySQL连接器的配置我使用MSK连接器与debezium自定义插件和Debezium版本1.8。

浏览 9提问于2022-03-15得票数 0

回答已采纳

1回答

Debezium连接器无法连接到MariaDB，错误'LOAD DATA LOCAL INFILE at is disabled at client‘

mariadb、debezium

对于大多数数据库，连接器都能成功运行，但有一个数据库的连接器会失败，并显示以下错误： at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:218) at io.debezium.conn

浏览 0提问于2021-01-12得票数 0

2回答

Kafka JDBC连接器-尝试将AvroConverter架构注册表详细信息作为新列添加到目标表中

apache-kafka、kafka-consumer-api、apache-kafka-connect

这里的问题是，当我试图从集群读取数据时，它试图将这些模式字段作为附加列添加到我的目标表中，并引发一个错误： INFO Unable to find fields [SinkRecordField{schema=Schema{Tab1.Value:STRUCT}, name='after', isPrimaryKey=false}, SinkRecordField{schema=Schema{io.debezium.connector.oracle.SourceError: Cannot ALTER TABLE "Tab1&qu

浏览 16提问于2022-04-10得票数 1

回答已采纳

1回答

删除"table.include.list“并不强制Debezium为数据库中的其余表创建主题。

mysql、apache-kafka-connect、debezium

我创建了Debezium连接器，它的工作原理就像一个魅力： "name": "debezium_title", "connector.class奇怪的是，它只为我在"table.include.list"中为第一个连接器设置的表创建了主题！kafka-topics --list --zookeeper xxx.xxx:2181 mysql

浏览 1提问于2021-04-23得票数 1

1回答

由于错误代码1236，无法启动debezium MySQL连接器

mysql、apache-kafka、apache-kafka-connect、debezium

当我通过kakfa-connect的REST检查debezium连接器的状态时，我看到连接器的错误消息： org.apache.kafka.connect.errors.ConnectException错误代码: 1236；SQLSTATE: HY000.\n\tat io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:230)\n\tat io.debezium.co

浏览 3提问于2021-04-19得票数 0

1回答

在一个位置管理两个关系数据库中的数据

google-bigquery、amazon-redshift、data-warehouse、bigdata

背景：我们目前将数据分割为两个关系数据库(Oracle )。需要运行涉及两个数据库中的表的临时查询。目前，我们正以两种方式之一这样做： ETL从一个数据库到另一个数据库。

浏览 5提问于2017-03-06得票数 1

回答已采纳

1回答

Debezium CDC连接器任务出现错误: javax.management.InstanceAlreadyExistsException

mysql、apache-kafka、apache-kafka-connect、debezium

我让我的debezium mysql源连接器在Kafka上工作。我使用相同的数据库添加了另一个debezium mysql源连接器，但具有不同的数据格式。结果，我的第一个连接器开始显示以下错误：at io.debezium.connector.<

浏览 274提问于2019-07-11得票数 0

1回答

Debezium连接器-通信链路故障

mysql、apache-kafka、docker-compose、apache-kafka-connect、debezium

当使用docker连接本地mysql时，我遇到了问题 { "config": { "connecto

浏览 10提问于2022-04-27得票数 0

回答已采纳

1回答

通过Debezium复制mysql :缺少表

apache-kafka-connect、debezium

我在MySQL database中有三个表table2和Debezium MySQL连接器： "name": "debezium_mysql_1","config": { "connector.class": "io.debezium.connector.mysql.MySqlConnector"

浏览 1提问于2021-05-26得票数 0

2回答

Debezium MySQL连接器-MySQL

maven、quarkus、mysql-connector、debezium

Debezium mysql连接器在快照的最后阶段失败。这个项目是在maven/quarkus上进行的，我想使用debezium/无穷大容量来实现缓存失效。在io.debezium.connector.mysql.antlr.MySqlAntlrDdlParser.extractCharset(MySqlAntlrDdlParser.java:404) at(CreateAndAlterDatabaseParserListener.java:49) at io.<em

浏览 33提问于2021-12-09得票数 0

1回答

Debezium连接器如何处理错误？

apache-kafka、apache-kafka-connect、confluent-platform、debezium、debezium-engine

我计划使用MySQL Debezium连接器，并对错误处理的配置提出疑问。我试图理解这是否适用于Debezium连接器。

浏览 3提问于2022-06-01得票数 0

2回答

卡夫卡连接未能添加MySqlConnector

apache-kafka、apache-kafka-connect、debezium

我遵循教程，但是我很难使用Debezium MySql连接器将MySQL连接到卡夫卡服务器。操作系统: Windows 10。我有档案我添加插件路径当我试图连接到Kafka Connect时，它给了我一个错误。“未能找到实现连接器且名称与io.debezium.con

浏览 2提问于2018-08-14得票数 3

回答已采纳

2回答

将数据从kafka复制到mysql，不能用DOcker和Debezium连接到DOcker。

mysql、apache-kafka-connect、debezium

嗨，我正在使用debezium捕获Mongo中的更改并将它们推入mysql --我使用下面的链接将end替换为mysql数据库，但我无法这样做。这是我修改过的jdbc-sink.json，在这里我使用mysql url进行连接。='source'，location='file:/kafka/connect/debezium-connector-mongodb/'}，PluginDesc{klass=class

浏览 0提问于2019-11-06得票数 0

1回答

Debezium错误，此连接器不知道架构

database、jboss-tools、debezium、apache-pulsar

我有一个使用Debezium的项目，主要基于，然后连接到Apache Pulsar。database.history=io.debezium.relational.history.MemoryDatabaseHistory connector.class=io.debezium.connector.mysql.MySqlConnector无论我使用哪种快照模式，在写入偏移量之后，我都无法在下次更新数据库时重启Debezium，而不会收到<

浏览 141提问于2019-07-22得票数 2

回答已采纳

1回答

通过binlog将MySQL复制到非MySQL数据库的最佳实践

mysql、replication

有许多阅读MySQL二进制日志的工具，例如钨、麦克斯韦、StreamSets、Debezium、Talend、Attunity等。它们都要求在MySQL中启用二进制日志，并且在编写二进制日志时读取它们。一种方法是停止数据库，以便不再向其写入数据，将数据复制到目标系统，启用binlog，然后重新启动。接下来，增量更改将被附加到目标系统，在我的例子中，目标系统不是MyS

浏览 1提问于2018-06-19得票数 1

回答已采纳

1回答

使用Debezium使用SSL连接到Cloud时出错

mysql、ssl、apache-kafka-connect、debezium

启用SSL后，将pem文件(server-ca.pem、client-cert.pem、client-key.pem)转换为密钥存储库和信任存储库，并将它们作为debezium连接码头容器容器中的文件挂载，然后在Debezium容器日志中得到一个错误(在向端点发送POST请求之后)： at io.debezium.co

浏览 0提问于2019-04-11得票数 1

回答已采纳

1回答

连接器任务状态无法连接

java、apache-kafka、apache-kafka-connect、debezium

连接器的任务状态因错误而失败： "connector.class": "io.debezium.connector.mysql<

浏览 0提问于2018-08-27得票数 0

回答已采纳

1回答

如何为mysql数据库创建多个Debezium连接

docker、apache-kafka、apache-kafka-connect、debezium

我正在尝试为mysql数据库连接多个Debezium连接器，我的配置如下。sudo docker run -it --name zookeeper -p 2181:2181 -p 2888:2888 -p 3888:3888 debezium/zookeeper:1.5 &sudo docker run -it --name kafka -p 9092:9092 --link zookeeper:zookeeper debezium/kaf

浏览 1提问于2021-06-07得票数 0

点击加载更多