mongodb - Debezium 无法捕获来自 MongoDB 的更改

Question

我在 Kafka connect 2.2 上使用 debezium mongo connnect 1.4.2。似乎“collection.include.list”配置阻止了 Debezium 获取收集数据更改。如果我删除 collection.include.list 配置，捕获将开始工作。但将适用于我不想要的所有集合。

谁能给我一些关于如何配置 collection.include.list 的例子？我尝试输入 '<db_name>[.]<collection_name>' ，但是我不断收到此警告并且没有捕获任何数据。

[2021-04-03 07:58:21,971] WARN 应用包含/排除列表过滤器后，将不会捕获任何更改。请检查您的配置！(io.debezium.connector.mongodb.MongoDbSchema:96) 我的配置如下：

{
  "name": "pipeline-mongo-connector",
  "config": {
    "connector.class": "io.debezium.connector.mongodb.MongoDbConnector",
    "mongodb.hosts": "xxxx_host:3717",
    "mongodb.name": "pipeline_mongo",
    "mongodb.user": "xxxxxxx",
    "mongodb.password":"xxxxxx",
    "collection.include.list": "prod-datapipeline[.]*"
  }
}

谢谢！

标签： mongodbapache-kafka-connectdebezium