Debezium docker 与连接 table.include.list 不工作

Question

我正在使用此示例将 elasticsearch 与 mssql 同步 https://github.com/debezium/debezium-examples/tree/master/unwrap-smt#elasticsearch-sink

我正在运行ning debezium 1.5 使用此 mssql 连接设置：

{
    "name": "Test-connector", 
    "config": {
        "connector.class": "io.debezium.connector.sqlserver.SqlServerConnector", 
        "database.hostname": "192.168.1.234", 
        "database.port": "1433", 
        "database.user": "user", 
        "database.password": "pass", 
        "database.dbname": "Test", 
        "database.server.name": "MyServer",
        "table.include.list": "dbo.TEST_A",
        "database.history.kafka.bootstrap.servers": "kafka:9092", 
        "database.history.kafka.topic": "dbhistory.testA"
    }
}

根据 debezium https://debezium.io/documentation/reference/connectors/sqlserver.html table.include.list

An optional comma-separated list of regular expressions that match fully-qualified table identifiers for tables that you want Debezium to capture; any table that is not included in table.include.list is excluded from capture. Each identifier is of the form schemaName.tableName. By default, the connector captures all non-system tables for the designated schemas. Must not be used with table.exclude.list.

当我运行这个连接器 kafka 不尊重 table.exclude.list。列出主题显示已捕获所有表。 TEST_A 主题也在那里。我也试过 "snapshot.include.collection.list": "Test.dbo.TEST_A" 没有结果。我错过了什么？

Answer 1

我发现它应该是 table.whitelist 而不是 table.include.list。不知道为什么。

Debezium docker 与连接 table.include.list 不工作

Debezium docker with connect table.include.list not working

apache-kafka-connect

debezium