按照这个连接: 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