ebe*_*ing 6 apache-kafka-connect
我正在使用Kafka Connect JDBC连接器,并专门查看放在该主题上的数据的实际格式.
我已经能够看到数据库的新插入和更新,但我无法检测数据库中的删除.
第一:JDBC源是否支持检测这些更改？我无法以这种或那种方式找到文档.
如果是这样,它对实际主题采取什么格式？
Ran*_*uch 11
该汇合JDBC源连接器能够捕捉到"软删除",这里的"删除"行被简单地标注,您的应用程序,但实际上并没有从表中删除.由于行仍然存在,连接器可以看到它们的更改.但是,连接器无法捕获从表中删除的行,因为连接器通过JDBC查询源表,因此无法查看从表中删除的行.
其他连接器能够通过使用称为更改数据捕获或CDC的技术,通过访问数据库事务日志或预写日志来捕获所有更改.每个DBMS都不同,因此需要专门为该DBMS编写的连接器.例如,Debezium项目具有适用于MySQL,PostgreSQL和MongoDB的Kafka Connect连接器,并且正在开发用于Oracle和SQL Server的连接器.
| 归档时间： |
|
| 查看次数： |
2966 次 |
| 最近记录： |