Свойства коннектора Debezium mongodb для ограничения cdc определенными коллекциями

Question

Можем ли мы ограничить объем данных, которые мы получаем в свойствах коннектора в конфигурациях коннектора debezium mongodb. Поскольку debezium ищет cdc в базе данных и, как я понимаю, это для всей базы данных, и я не мог найти способ ограничить несколько конкретных коллекций. Я использую ссылку для подключения атласа mongodb в моем разъеме debezium.

Ниже приведены мои конфигурации коннекторов:

{
    "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"
    }
}

Как настроить поиск только определенных коллекций в моей базе данных?

Answer 1

Согласно документации Debezium Connector для MongoDB, вы можете использоватьcollection.whitelist в конфигурации коннектора, чтобы решить вашу проблему