这个问题可能是由于您的Flink CDC配置中缺少了mongo-cdc.start.at
参数导致的。这个参数用于指定从哪个时间点开始读取数据,如果不设置该参数,则默认为null
,这可能会导致同步过程中出现BsonInvalidOperationException
异常。
您可以尝试在Flink CDC的配置文件中添加以下参数:
mongo-cdc.start.at=<时间戳>
其中,<时间戳>
表示您希望从哪个时间点开始读取数据。例如,如果您希望从2023年1月1日开始读取数据,可以将其设置为:
mongo-cdc.start.at=1672444800000
请注意,时间戳的单位是毫秒。