我们能否限制在debezium mongodb中的连接器属性中检索的数据量连接器配置。由于debezium在数据库中查找cdc,根据我的理解,它适用于整个数据库,因此我找不到限制的方法几个特定的收藏。我在我的debezium连接器中使用mongodb atlas连接链接。
下面是我的连接器配置:
{
"name": "inventory-connector",
"config": {
"connector.class" : "io.debezium.connector.mongodb.MongoDbConnector",
"tasks.max" : "1",
"mongodb.hosts" : "mongodb+srv link",
"mongodb.name" : "database",
"mongodb.user" : "user1",
"mongodb.password" : "password",
"mongodb.ssl.enabled" : true,
"database.whitelist" : "db[.]*",
"database.history.kafka.bootstrap.servers" : "kafka:9092",
"transforms": "route",
"transforms.route.type" : "org.apache.kafka.connect.transforms.RegexRouter",
"transforms.route.regex" : "([^.]+)\\.([^.]+)\\.([^.]+)",
"transforms.route.replacement" : "$3"
}
}
如何将其配置为仅查找特定的收藏夹在我的数据库中?
根据Debezium Connector for MongoDB documentation您可以在连接器配置上使用collection.whitelist
解决您的问题