Kafka 连接源和目标之间的记录计数不匹配

Question

我们正在使用 kafka connect JDBC 连接器使用 jdbcsource 连接器从 oracle DB 中的表中获取数据，并使用 jdbc sink 连接器通过主题将其上传到 postgres DB 中的目标表。在执行此活动时，我们能够从源获取数据并将其更新到目标表。但是源表中的记录数与目标数据库中的记录数不匹配。有没有办法检查

1.  the data fetched by the source connector and uploaded in the topic 
2.  Any way to track the records and identify why its not uploaded in the target table.  
3. How to identify the records that has not been uploaded into the target based on the log details.

Answer 1

我们能找到解决方案吗？