flink cdc 连接mongo数据库。想用datastream读取整库方式。现在报错什么原因？

在Flink CDC中连接MongoDB数据库时，您可以使用MongoDBSource来实现。然而，根据您提供的代码和错误信息，似乎在配置collectionList时出现了问题。

根据错误信息，{aggregate: 1} is not valid for '$changeStream'; a collection is required，看起来您未指定要读取的具体集合（collection）。collectionList应该传递一个字符串集合，表示要读取的集合列表。

您需要将.collectionList()替换为.collectionList("your_collection_name")，将your_collection_name替换为您要读取的具体集合名称。如果您希望读取多个集合，可以传递一个包含所有集合名称的字符串列表。

以下是示例代码，演示如何连接MongoDB并读取指定的集合：
```MongoDBSource mongoSource = MongoDBSource.builder()
.hosts(Config.DB_HOST + ":" + Config.DB_PORT)
.databaseList(Config.DB_KUSER)
.collectionList("your_collection_name") // 指定要读取的集合名称
.username(Config.DB_USER)
.password(Config.DB_PAWD)
.deserializer(Config.DEBEZIUM_DESER)
.build();

```
请确保将your_collection_name替换为您要读取的实际集合名称。

这样应该能够解决报错并成功连接MongoDB数据库进行读取整库操作。