无法使用debezium作为源和合流jdbc接收器连接器获取目标数据库中的删除更改。
Debezium是一个开源的分布式平台，用于捕获数据库的变更事件并将其转发到消息队列中。它支持多种数据库，包括MySQL、PostgreSQL、MongoDB等。Debezium的工作原理是通过数据库的事务日志来捕获变更事件，然后将这些事件转换为可消费的消息。
在使用Debezium作为源和合流JDBC接收器连接器获取目标数据库中的删除更改时，可能会遇到一些问题。以下是一些可能导致无法使用Debezium获取删除更改的常见原因：
- 配置错误：确保Debezium的配置正确无误。检查Debezium连接器的配置文件，包括数据库连接信息、表的白名单或黑名单等。
- 数据库权限问题：确保连接到目标数据库的用户具有足够的权限来捕获删除更改。有时候，数据库用户可能没有足够的权限来访问事务日志或读取删除更改。
- 数据库日志模式不支持：Debezium依赖于数据库的事务日志来捕获变更事件。某些数据库的日志模式可能不支持删除更改的捕获。在这种情况下，您可以尝试使用其他捕获变更的方法，如触发器或轮询。
- 数据库版本不兼容：确保您使用的数据库版本与Debezium兼容。某些数据库版本可能不支持Debezium的特定功能或API。
如果您遇到无法使用Debezium获取删除更改的问题，建议您参考Debezium的官方文档和社区支持，以获取更详细的解决方案和帮助。
腾讯云提供了一系列与云计算相关的产品和服务，包括云数据库、云服务器、云原生应用引擎等。您可以根据具体需求选择适合的产品来支持您的云计算需求。以下是一些腾讯云相关产品和产品介绍链接地址：
- 云数据库MySQL：https://cloud.tencent.com/product/cdb_mysql
- 云服务器CVM：https://cloud.tencent.com/product/cvm
- 云原生应用引擎TKE：https://cloud.tencent.com/product/tke
请注意，以上链接仅供参考，具体产品选择应根据实际需求和情况进行评估和决策。
相关·内容
我需要将MySQL数据库复制到PostgreSQL数据库。我选择了：
Debezium连接
Avro格式
合流模式注册表
卡夫卡
数据正在被复制，但是，我正在丢失一些模式信息。例如，在Postgres中将具有mysql格式的datetime格式的列复制为bigint，没有创建外键，也没有保留列的顺序(这很好)，等等。
PostgreSQL接收器连接器：
{
"name": "jdbc-sink-dbt",
"config": {
"connector.class": "
浏览 1提问于2022-01-14得票数 0
回答已采纳
我在用debezium捕获mysql中的数据时遇到了问题，将数据捕获并使用kafka连接jdbc接收器将其消费到另一个mysql。
因为debezium对kafka主题产生的模式和有效负载与kafka连接jdbc接收器所期望的模式不兼容。
当jdbc接收器想要使用数据并在另一个mysql中创建记录时，我就会异常。
我该如何解决这个问题？
浏览 2提问于2017-05-14得票数 1
回答已采纳
我试图使用MySQL将事件流到PostgreSQL，尽管插入和更新工作正常，但我不知道如何从MySQL中删除记录并将该事件流到PostgreSQL。
假设以下拓扑结构：
+-------------+
| |
| MySQL |
| |
+------+------+
|
|
浏览 4提问于2017-12-18得票数 5
我的Dockerfile，用于下载接收器连接器和mysql jdbc驱动程序 FROM debezium/connect
ENV KAFKA_CONNECT_JDBC_DIR=$KAFKA_CONNECT_PLUGINS_DIR/kafka-connect-jdbc
ENV MYSQL_DRIVER_VERSION 5.1.39
ARG KAFKA_JDBC_VERSION=5.5.0
RUN curl -k -SL "https://dev.mysql.com/get/Downloads/Connector-J/mysql-connector-java-${MYSQL_DRIVER
浏览 34提问于2020-07-07得票数 0
回答已采纳
嗨，我正在使用debezium捕获Mongo中的更改并将它们推入mysql --我使用下面的链接将end替换为mysql数据库，但我无法这样做。
这是我修改过的jdbc-sink.json，在这里我使用mysql url进行连接。
{
"name" : "jdbc-sink",
"config" : {
"connector.class":"io.confluent.connect.jdbc.JdbcSinkConnector",
"tasks.max"
浏览 0提问于2019-11-06得票数 0
我想使用Debezium实现PostgreSQL数据库上的更改数据捕获(CDC)。现在，我还不完全理解如何处理Debezium的交易。
让我们考虑下面的示例--我在源PostgreSQL数据库中有两个表。我在单数据库事务范围内将数据插入到这两个表中。换句话说，我必须执行两个单独的INSERT语句。如果我对Debezium CDC的理解是正确的，那么它将产生两个单独的消息，分为两个单独的Kafka主题(或AWS动态流)。每个消息都将由自己的使用者使用，并在单独的事务中插入到目标数据库中。如果其中一个事务失败，另一个事务可能会成功，我将在目标数据库中遇到数据不一致状态。
Debezium是否有任何
浏览 2提问于2020-08-08得票数 1
回答已采纳
我正在使用Confluent社区平台中的Kafka来保持MySQL数据库的同步。源和汇是MySQL数据库。它没有起作用。
在我的情况下，有一些问题：
在同一台服务器中的其他数据库中有表，我不想将它们读入Kafka，但是Kafka继续尝试读取其他数据库。
我希望在源连接器和Sink连接器中都使用org.apache.kafka.connect.json.JsonConverter，但是接收器连接器无法正确插入。
我想同步几个数据库，不同数据库中的表可能具有相同的表名，如何避免表名冲突和接收器连接器正确路由卡夫卡主题以将数据插入正确的数据库？
Kafka JDBC Source
浏览 0提问于2019-02-19得票数 0
我已经使用debezium-connector-postgres-1.8.0.Final-plugin connector.Below是我的Standalone.properties文件成功地将postgresql连接到kafka：
rest.port=8084
bootstrap.servers=localhost:9092
key.converter=org.apache.kafka.connect.storage.StringConverter
value.converter=org.apache.kafka.connect.json.JsonConverter
key.convert
浏览 3提问于2022-02-08得票数 0
回答已采纳
1回答
我在容器中有Debezium，捕获PostgeSQL数据库记录的所有更改。此外，还有一个汇合JDBC容器可以将所有更改写入另一个数据库。
在源连接器中，定义允许捕获多个表，因此有些表具有主键，而另一些则没有。
在接收器连接器中，定义指定pk.mode，如下所示：
"insert.mode": "upsert",
"delete.enabled": "true",
"pk.mode": "record_key",
但是，虽然源数据库中有表中没有键的表，但接收器连接器正在抛出以下消息：
Caused b
浏览 8提问于2022-11-01得票数 0
使用JDBC同步连接器获取以下错误。
ERROR WorkerSinkTask{id=12sink-0} Task threw an uncaught and unrecoverable exception. Task is being killed and will not recover until manually restarted. Error: Cannot ALTER TABLE "new1501"."test"."patient3" to add missing field SinkRecordField{schema=Sche
浏览 7提问于2022-02-11得票数 0
我试图使用Debezium的MongoDB源代码连接器(版本1.5.0)和Confluent的JDBC连接器(版本10.1.1)，通过Kafka将MongoDB (4.2.0版)与PostgresDB (版本10)连接起来。
对于源连接器，我有以下配置：
name=mongodb-debezium-source-connector
connector.class=io.debezium.connector.mongodb.MongoDbConnector
tasks.max=1
mongodb.hosts=rs0/127.0.0.1:27019
mongodb.name=gtmhub
tomb
浏览 9提问于2021-04-22得票数 1
1回答
我正在使用Debezium PostgreSQL连接器将用户表转换为一个Kafka主题。
我有一个JDBC Sink连接器，然后从主题中读取数据并将其推入自己的数据库中。
现在，我需要另一个Microservice数据库的数据子集。因此，我计划编写另一个JDBC Sink连接器。
问题:使用现有的users表主题是一个很好的实践吗？如果是，那么我如何确保新的JDBC连接器是整个users表的快照
浏览 6提问于2022-05-26得票数 1
我能够从捕获数据事件。我遵循了 的所有步骤，但在本教程中，它们没有指定如何将这些更改转移到另一个mysql。请帮助我，我被困在它，我找不到适当的教程。
docker run -it --rm --name mysql -p 3307:3306 -e MYSQL_ROOT_PASSWORD=debezium -e MYSQL_USER=mysqluser -e MYSQL_PASSWORD=mysqlpw debezium/example-mysql:1.1
我正在捕获这个mysql db中的更改，它位于端口3307上。
docker run -it --rm --name mysqltes
浏览 3提问于2020-06-19得票数 0
我想使用Kafka Connect通过CDC检测Postgres DB对一组表的更改，并将它们作为单个主题中的消息推送，使用key作为主表的逻辑键。
这将使使用者能够以正确的顺序使用数据更改，以便将它们应用于目标数据库。
是否有Source和Sink连接器允许我实现此目标？
我正在使用Debezium CDC Source Connector for Postgres...我可以配置它将所有表的所有消息路由到一个单独的主题中。
但是，我找不到能够使用消息的Sink连接器，并且无法根据消息的模式写入正确的表。
浏览 1提问于2021-09-23得票数 0
我使用Kafka和Kafka将MySQL数据库复制到MySQL，使用源连接器和汇流JDBC接收器连接器。"auto.create“设置为true，接收器连接器确实创建了表，但有些数据类型不匹配。在SQL Sever中，我有
CREATE TABLE employees (
id INTEGER IDENTITY(1001,1) NOT NULL PRIMARY KEY,
first_name VARCHAR(255) NOT NULL,
last_name VARCHAR(255) NOT NULL,
email VARCHAR(255) NOT NULL UNIQUE
浏览 15提问于2022-03-04得票数 0
以下代码是我用于Kafka-connect-JDBC和MySQL-driver的Dockerfile FROM debezium/connect:1.3
ENV KAFKA_CONNECT_JDBC_DIR=$KAFKA_CONNECT_PLUGINS_DIR/kafka-connect-jdbc
ENV MYSQL_DRIVER_VERSION 8.0.20
ARG KAFKA_JDBC_VERSION=5.5.0
RUN curl -k -SL "https://dev.mysql.com/get/Downloads/Connector-J/mysql-connector-jav
浏览 39提问于2020-10-16得票数 1
回答已采纳
我们正在尝试将数据库从mysql转移到couchbase，并实现一些CDC ()逻辑，以便将数据复制到我们的新数据库。
所有环境的设置和运行。mysql，debezium，kafka，couchbase，kubernetes，管线等，我们还为debezium安装了kafka源连接器.下面是：
- name: "our-connector"
config:
connector.class: "io.debezium.connector.mysql.MySqlConnector"
tasks.max
浏览 18提问于2022-07-01得票数 2
我使用获取数据事件，使用kafka-connect-jdbc接收更改。
这是我的Dockerfile文件，我正在使用mysql-connector-java-5.1.39.jar
FROM debezium/connect:1.1
ENV KAFKA_CONNECT_JDBC_DIR=$KAFKA_CONNECT_PLUGINS_DIR/kafka-connect-jdbc
ENV MYSQL_DRIVER_VERSION 5.1.39
ARG KAFKA_JDBC_VERSION=5.3.1
RUN curl -k -SL "https://dev.mysql.com/get/
浏览 5提问于2020-06-20得票数 0
1回答
我使用部署在Kafka中的Debezium MySQL连接器来流MySQL对Kafka的更改，我们从那里获取这些消息，丰富数据并将数据推送到另一个MySQL。
源和汇都是MySQL。
源表中有两列，列数据类型为时间戳。
例：create_time : 2021-10-06 :32:46
我可以在下面的Kafka消息中看到上面的数据
"create_time":"2021-10-06T09:32:46Z"
当消息加载到目标数据库(数据库，MySQL)中时，将在上面的字符串中遇到T和Z的问题，在目标数据库中，数据类型也是时间戳。
我需要create_time在卡夫卡
浏览 13提问于2021-12-22得票数 0
1回答
目标是: MySQL -> Kafka -> MySQL。接收器目标应与生产环境保持同步。
插入和删除记录是很好的，但是我遇到了模式更改的问题，例如删除的列。更改不会复制到接收器目标。
我的消息来源：
{
"name": "hub-connector",
"config": {
"connector.class": "io.debezium.connector.mysql.MySqlConnector",
"database.hostname
浏览 22提问于2021-06-01得票数 0
因此，我正在阅读有关连接器1的文档，并试图找出流和接收器连接器2之间的关系。
源连接器3有一个名为"table.whitelist“的属性，据我所知，该属性告诉Debezium只将这些表复制到ksqldb。我在这里的解释也是，CDC也用来将那些源表上发生的更改与ksqldb同步，但没有提到。
但是，单独的流和接收器连接器之间的关系呢？没有像"stream.whitelist“这样的属性。这是否真的意味着所有的流都会被发送到所有的连接器？
例如，我只想从流str1向连接器con1发送数据，只向con2发送流str2。这有可能吗？
浏览 3提问于2022-08-07得票数 0
在连接器post请求创建过程中，我收到以下错误：
Error message : 500 Internal Server Error,
error response: {"error_code":500,"message":"org.apache.kafka.connect.runtime.distributed.RebalanceNeededException: Request cannot be completed because a rebalance is expected"}
Requst body:
{"name"
浏览 22提问于2019-07-16得票数 0
debezium MySQL连接器产生的Kafka消息密钥类似于Struct{id=1}而不是1。
我的配置如下所示：
connector.class=io.debezium.connector.mysql.MySqlConnector
name=mysql-source
database.server.name=dbserver1
tasks.max=1
database.hostname=127.0.0.1
database.port=3306
database.user=root
database.password=*****
database.server.id=1
topic.cre
浏览 1提问于2021-08-05得票数 0
回答已采纳
我们使用Debezium和Kafka-Connect从几个MariaDB数据库实例中获取数据。对于大多数数据库，连接器都能成功运行，但有一个数据库的连接器会失败，并显示以下错误：
at io.debezium.connector.mysql.AbstractReader.wrap(AbstractReader.java:241)
at io.debezium.connector.mysql.AbstractReader.failed(AbstractReader.java:218)
at io.debezium.connector.mysql.SnapshotReade
浏览 0提问于2021-01-12得票数 0
我使用过Debezium作为Mysql的-> Elasticsearch。现在的问题是，当我从MySQL中删除数据时，它仍然会在Elasticsearch中重新出现，即使数据不再存在于MySQL DB中。UPDATE和INSERT工作正常，但DELETE不是。另外，我做了以下工作：
Delete在MySQL中的数据
Delete Elasticsearch索引和ES Kafka Sink
Create -- Kakfa中ES的新连接器
现在，奇怪的是，所有我删除的数据收割机在这里，以及！当我在步骤(3)之前检查ES数据时，数据不存在。但之后，这种行为会被观察到。
请帮我解决这个问题！
M
浏览 7提问于2021-03-14得票数 0
星期四快乐！我一直在尝试在Debezium中创建一个连接器Postgres连接器，但只有当表已经存在于我的MySQL实例(这并不理想)时，我才能捕获更改。因为那样的话，我将不得不用Python编写一个脚本来处理这样的事件，而且使用已经存在的东西可能比重新发明轮子更容易。我希望能够在实际连接器中捕获DDL。我偶然看到这篇博文。和我让它在我的本地设置上工作，这是很棒的，但唯一的问题是我想朝相反的方向发展。(我能够捕获新的记录、删除的记录和更新的记录，如果新表和新列不存在，它也会创建它们)。我希望从postgres流并让连接器插入到mysql中的目标db中。我试着分别切换jdbc源和接收器连接器，但
浏览 6提问于2022-07-21得票数 0
回答已采纳
1回答
复制槽已存在
、、
每当我重启debezium kafka-connect容器，或者部署另一个实例时，我都会得到以下错误：
io.debezium.jdbc.JdbcConnectionException: ERROR: replication slot "debezium" already exists
at io.debezium.connector.postgresql.connection.PostgresReplicationConnection.initReplicationSlot(PostgresReplicationConnection.java:136)
浏览 0提问于2018-06-08得票数 6
我有这个debezium源连接器和一个jdbc接收器连接器，如下所示：
{
"name": "smartdevsignupconnector111",
"config": {
"connector.class": "io.debezium.connector.mysql.MySqlConnector",
"tasks.max": "1",
"key.converter": "org.apache.kafka.connec
浏览 9提问于2022-11-12得票数 1
回答已采纳
我正在尝试将数据从Kafka集群加载到Oracle DB中。集群中的数据已使用AvroConverter加载，模式详细信息还包含源、op、ts_ms等字段。这里的问题是，当我试图从集群读取数据时，它试图将这些模式字段作为附加列添加到我的目标表中，并引发一个错误：
INFO Unable to find fields [SinkRecordField{schema=Schema{Tab1.Value:STRUCT}, name='after', isPrimaryKey=false}, SinkRecordField{schema=Schema{io.debezium.conn
浏览 16提问于2022-04-10得票数 1
回答已采纳
我们希望根据操作类型来区分Kafka(它来自Debezium)中的消息。我们正在寻找基于卡夫卡操作类型的路由消息。
Debezium发送不同类型的操作类型，如r(读)、u(更新)、删除(D)等。
就像这样
如果操作=r ->发送到桶1
如果操作= u，d ->发送到桶2
我们希望将快照和增量数据从Debezium中分离出来。
浏览 5提问于2022-07-06得票数 0
1回答
汇合云只支持以下连接器.
- GCS Sink Connector
- S3 Sink Connector Please validate If my understanding is correct or not.
我们可以像debezium一样在合流云中部署自定义连接器或cdc。
浏览 2提问于2019-09-18得票数 0
回答已采纳
正如标题所述，我使用debezium Postgres源连接器，并且我希望MongoDB接收器连接器根据不同的集合和数据库(也不同的dbs来分离无关数据)中的名称对kafka主题进行分组。在询问时，我在上看到了连接器属性。不幸的是，这只为每个kafka主题创建了一个集合，该集合成功地与指定的regex匹配，我计划使用相同的mongodb服务器来存储从多个debezium源连接器中捕获的许多dbs。你能帮帮我吗?
注意:我读过这个Mongo接收器设置FieldPathNamespaceMapper，但我不确定它是否符合我的需要，也不确定如何正确配置它。
浏览 14提问于2022-09-24得票数 0
我想建立一个Kafka连接器，以便从数据库中检索记录在接近实时。我的数据库是Oracle Database 11g企业版11.2.0.3.0版，表中有数百万条记录。首先，我想使用CDC将最小负载添加到我的数据库中。其次，我希望基于某个日期之后具有值的LastUpdate字段来检索记录。
在confluent的网站上搜索，我发现唯一的开源连接器是“Kafka Connect JDBC”。我认为这个连接器没有CDC机制，当连接器第一次启动时，它不可能检索数百万条记录。我认为另一种解决方案是Debezium，但Confluent的网站上没有Debezium Oracle Connector，我相信它
浏览 2提问于2019-06-27得票数 5
我正在使用合流云通过SObject sink连接器从Kafka到Salesforce接收一些数据。连接已建立，但我遇到了一个错误：“卡夫卡记录丢失了用于标识_ObjectType的键SObject，请在记录中包含_ObjectType字段”。有人知道哪里出错了吗？
Google搜索并没有那么有用，因为它们引导我了解Kafka键/值概念，它主要用于维护消息的顺序。
浏览 11提问于2021-12-20得票数 0
我试图使用Kafka在MongoDB和Elasticsearch之间建立一条简单的管道。插入的数据被成功地存储在Elasticsearch中，但是当我编辑或删除文档时，我只会得到另一个存储在Elasticsearch中的文档。这是我的MongoDB源连接器
{ "name": "mongo-source", "config": { "connector.class": "io.debezium.connector.mongodb.MongoDbConnector",
"mongodb.hosts&
浏览 4提问于2020-04-28得票数 0
回答已采纳
当我创建kafka jdbc源连接器(用于oracle的debezium连接器，使用confluent-5.4.0)时，收到错误消息“没有找到适用于jdbc的驱动程序:oracle:oci...”。
[2020-03-23 11:49:44,521] ERROR WorkerSourceTask{id=debezium-souce-inventory-0} Task threw an uncaught and unrecoverable exception (org.apache.kafka.connect.runtime.WorkerTask:179)
org.apache.kafka.co
浏览 3提问于2020-03-23得票数 1
我使用debezium cdc连接pg，我构建了由码头使用的pg 11，pg运行良好。当我在kafka连接器中使用debezium时，它报告：
无法获得数据库测试的编码
卷曲是：
curl -H "Accept: application/json" -H "Content-type: application/json" -X POST http://localhost:8083/connectors/ -d '{
"name": "debezium",
"config": {
浏览 18提问于2020-07-08得票数 3
回答已采纳
mysql模式 `Info` longtext, 相同字段的debezium模式 {
"name": "Info",
"type": [
"null",
"string"
],
"default": null
}, 当这些数据加载到Redshift中时，它会失败，因为它希望数据类型是大的，即VARCHAR(MAX)，但它得到了VARCHAR(255)，因为debezium没有将长文本转换为long。 请建议一
浏览 67提问于2020-09-14得票数 0
我正在为一个数据库表开发kafka-connect JDBC接收器连接器。
我在将pk.mode配置为支持自动递增的合适的auto时遇到了问题。最初，我将pk.mode设置为默认的"none“，并希望数据库会自动插入主键递增1的新记录。然而，我得到一个错误，抱怨主键不能为"null“。
我尝试了几乎所有的其他模式，现在已经没有想法了。我想知道接收器连接器是否支持pk.mode为“自动递增”？
浏览 13提问于2021-06-04得票数 0
回答已采纳
我对Kafka非常陌生(从一个星期开始在我的Sandbox环境中阅读和设置)，并尝试设置Server连接器。我已经按照汇合指南安装了Confluent社区，并使用confluent集线器安装了io.debezium.connector.sqlserver.SqlServerConnector，我在Server数据库和required表上启用了CDC，而且它工作得很好。
我尝试过以下连接器(一次一次)：
io.debezium.connector.sqlserver.SqlServerConnectorio.confluent.connect.jdbc.JdbcSourceConnector
这
浏览 4提问于2020-06-05得票数 0
回答已采纳
在设置源连接器和接收器连接器之后，我会发现DATE类型Postgres列的问题。
错误："foo“列为日期类型，而表达式为整数类型
我检查了Avro模式，发现列foo被序列化为io.debezium.time.Date。
{
"default": null,
"name": "foo",
"type": [
"null",
{
"connect.name": "io.debezium.time.Date
浏览 1提问于2019-12-03得票数 2
回答已采纳
我在尝试使用Camel Debezium SQL服务器连接器时遇到了一个问题。我正在尝试使用camel Debezium SQL server连接器捕获SQL server db表中的数据更改，并将它们放入message。我知道JDBC服务器连接可以选择使加密为false，以防止出现此问题。但我在Camel Debezium SQL服务器连接器中找不到类似的方法。
为了使用Camel Debezium SQL服务器连接器，我遵循了以下文档：
当我运行该应用程序时，它会显示以下错误：
错误-当试图运行由：'io.debezium.connector.sqlserver.SqlServ
浏览 41提问于2022-08-12得票数 2
回答已采纳
我正在使用Debezium、AWS + MSK和一个S3 Sink做一些Postgres工作。下面是Debezium + S3 Sink的工作配置。所有的权限+连接都已经设置好了。
数据库的更改正在被捕获&以JSON文件的形式存储到S3中，但在文件本身中，消息似乎是Structs (见下文)。
我希望消息看起来像这样(正确的JSON格式)。
Debezium Config
connector.class=io.debezium.connector.postgresql.PostgresConnector
database.user=user
database.dbn
浏览 4提问于2022-09-23得票数 0
回答已采纳
我在卡夫卡connect.While启动连接器中使用debezium oracle连接器，
java.lang.RuntimeException: Failed to resolve Oracle database version
at io.debezium.connector.oracle.OracleConnection.resolveOracleDatabaseVersion(OracleConnection.java:159)
at io.debezium.connector.oracle.OracleConnection.<init>(O
浏览 5提问于2021-09-07得票数 3
回答已采纳
我使用postgres配置了debezium，如下代码所示，当我启动我的spring引导应用程序时，a get an error Creation of replication slot failed @Bean
public io.debezium.config.Configuration connector() {
return io.debezium.config.Configuration.create()
.with(EmbeddedEngine.CONNECTOR_CLASS, PostgresConnector.class)
浏览 902提问于2021-04-02得票数 5
[用户在上发布的问题]
我有YB Debezium运行，我看到它可以访问桌子。这是日志：
2022-07-27 21:25:56,894 INFO AbstractConfig values:
(org.apache.kafka.common.config.AbstractConfig) [pool-3-thread-1]
2022-07-27 21:27:55,147 INFO Retrieving configuration from Secret debezium-secret in namespace default (io.strimzi.kafka.AbstractKuberne
浏览 11提问于2022-09-15得票数 0
回答已采纳
2回答
我目前正在配置kafka连接(使用)，我使用环境变量成功地将它连接到Kafka：
docker run -it --rm --name AAAAAA-kafka-connect -p 8083:8083 \
-v aaaaa.jks:aaaaa.jks \
-v bbbbbb.jks:bbbbbb.jks \
-e LOG_LEVEL=INFO \
-e HOST_NAME="AAAAAA-kafka-connect" \
-e HEAP_OPTS="-Xms256m -Xmx2g" \
-e BOOTSTRAP_
浏览 14提问于2022-05-24得票数 0
回答已采纳
从我的中，我决定更多地同意用户部署数据库实时同步的卡夫卡分布。同样的情况下，我有超过数百个表要从PostgreSQL拉到Server。从PostgreSQL到Kafka，我使用了带有wal2json插件的Debezium连接器。从Kafka到Server，我使用JDBC连接器。我有三个相同的经纪人(地址不同)：
broker.id=0
broker.rack=1
port=9093
listeners=PLAINTEXT://0.0.0.0:9093
advertised.listeners=PLAINTEXT://localhost:9093
log.dir=/home/admin/kafk
浏览 2提问于2020-04-15得票数 3
回答已采纳
2回答
使用debezium从Postgres中更改流
已完成的设置：
码头设置。
启动Postgres，动物园管理员，kafka，然后去贝兹姆连接器。
远程数据库设置与解码，wal2json(postgres)。
用卷曲连接到去贝兹姆。
创造了一个观察者。
问题:当我开始观察时，它正在读取前面发生的所有更改，但是当插入完成时，卡夫卡向debezium抛出一个异常，上面写着"An exception occurred in the change event producer. This connector will be stoppe
浏览 1提问于2019-05-02得票数 2
回答已采纳
1回答
我试图了解db.timezone属性是如何在源连接器和接收器连接器上工作的。
对于消息来源，文档说：
当查询基于时间的条件时，连接器中使用的JDBC时区的名称。默认为UTC。
这到底是什么意思？这应该设置为我的源数据库的时区吗？我有一个数据库被设置为东部时区。我需要把这个放到美国/东部吗？如果我不做，它会做什么？
在水槽边，医生们说：
插入基于时间的值时应在连接器中使用的JDBC时区的名称。默认为UTC。
再说一遍这到底意味着什么。它是否使用它将有效负载中的所有时间戳转换为您在这里给出的值？
我的具体问题是我的源db有东部时区，但是我的接收器db被设置为UTC，我不能更改它。我应该如何定义
浏览 1提问于2020-07-02得票数 0
回答已采纳
扫码
添加站长 进交流群
领取专属 10元无门槛券
手把手带您无忧上云
相关资讯
热门标签
云服务器
ICP备案
对象存储
即时通信 IM
腾讯会议活动推荐
腾讯云开发者
