标签: debezium-engine

我正在使用 Debezium（Kafka 连接器）来捕获 Postgres 数据库更改，但我从 Debezium 收到错误。有谁知道下面的错误意味着什么，并可能提供修复它的建议。

更多调试信息：

• 我尝试了 "schema.include.list": "banking" 和 "database.include.list": "banking"...都不起作用
• 我尝试了 debezium/connect:1.4 并且它可以工作...但不能与 debezium/connect:1.5+ 一起使用（1.9 是可用的最高版本，但它不起作用（与下面的错误相同）

Postgres|dbserver1|snapshot  After applying the include/exclude list filters, no changes will be captured. Please check your configuration!   [io.debezium.relational.RelationalDatabaseSchema]

我已经（在日志中）验证 Kafka（和模式注册表等）是否正常运行，并且 Debezium 连接器似乎已启动，Postgres iw 正常工作并且创建了数据库和表。

以下是 Debezium 连接器配置：

{
    "name": "banking-postgres-connector",
    "config": {
        "connector.class": "io.debezium.connector.postgresql.PostgresConnector",
        "database.hostname": "postgres",
        "database.port": "5432",
        "database.user": "postgres",
        "database.password": "postgres",
        "database.dbname" : "banking",
        "database.server.name": "dbserver1",
        "database.include.list": "banking",
        "tasks.max": "1",
        "table.include.list": "public.x_account,public.x_party,public.x_product,public.x_transaction"
    }
}