按照这个连接: https://debezium.io/documentation/reference/connectors/mongodb.html#mongodb-performing-a-snapshot 的说明,创建一个新名字的 connector,应该会执行 snapshot,实际上并没有同步任何数据,部分日志提示
After applying the include/exclude list filters, no changes will be captured. Please check your configuration
connector 配置:
{
"name": "mongo-material",
"config": {
"connector.class": "io.debezium.connector.mongodb.MongoDbConnector",
"mongodb.user": "",
"mongodb.password": "",
"mongodb.hosts": "overseatestmongo1/10.130.84.32:10020,overseatestmongo1/10.130.84.24:10017",
"mongodb.name": "test",
"MongoDB.authsource": "admin",
"database.include.list": "db_sky",
"collection.include.list": "db_sky.material",
"snapshot.include.collection.list": "db_sky.material",
"database.history.kafka.bootstrap.servers" : "kafka:9092",
"snapshot.mode": "initial",
"snapshot.max.threads": 2
}
}
完整日志 https://gist.github.com/zhiyue/0230830edb9b07b520152fc30d0f42d8