flink1.15.4通过upsert-kafka读取数据并同步到doris中部分数据丢失

[wandayou]

flink sql通过connector读取mongo数据->写入upsert-kafka后，再用upsert-kafka connector作为source端读取数据->写入doris后，发现会丢失部分数据。另外尝试source端使用普通kafka connector读取数据->写入到doris 数据则是完整的，请问这是什么原因？