Debezium docker 与 connect table.include.list 不起作用

Question

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

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

{
    "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 表.include.列表

可选的以逗号分隔的正则表达式列表，与您希望 Debezium 捕获的表的完全限定表标识符相匹配；任何未包含在 table.include.list 中的表都将从捕获中排除。每个标识符的形式为 schemaName.tableName。默认情况下，连接器捕获指定架构的所有非系统表。不得与 table.exclude.list 一起使用。

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

Answer 1

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

Answer 2

table.include.list 适用于较新版本的 Debezium table.whitelist 适用于 1.X