kafka 连接器如何用于 postgresql 和 mysql 数据库
How kafka connector works for postgresql and mysql database
我正在学习这里的快速入门教程 quick-start-kafka-connect
本教程介绍如何将 mysql 数据库 table 更改流式传输到 kafka 主题。
唯一的部分是下载所有内容并添加 /tmp/kafka-connect-jdbc-source.json 具有一些配置属性的文件并启动
这在后台如何工作？
1 : Does it create connection with database and monitor tables for specific intervals of time? OR
2 : Does it uses replication log? (i don't know how this works)
3 : Is this same mechanism for mysql and postgresql?
Debezium 监控 OpLog。
Confluent 的 Kafka Connect JDBC（您已链接到）可以使用时间间隔，并且该配置由所有 JDBC 兼容的连接共享，MySQL 和 Postgres包括。
For incremental query modes that use timestamps, the source connector uses a configuration timestamp.delay.interval.ms ...
replication log? (i don't know how this works)
您可以找到 the Debezium guide here，但此机制与 Mongo、Postgres、MySQL、MSSQL、Oracle 等不同。
我正在学习这里的快速入门教程 quick-start-kafka-connect
本教程介绍如何将 mysql 数据库 table 更改流式传输到 kafka 主题。
唯一的部分是下载所有内容并添加 /tmp/kafka-connect-jdbc-source.json 具有一些配置属性的文件并启动
这在后台如何工作？
1 : Does it create connection with database and monitor tables for specific intervals of time? OR
2 : Does it uses replication log? (i don't know how this works)
3 : Is this same mechanism for mysql and postgresql?
Debezium 监控 OpLog。
Confluent 的Kafka Connect JDBC（您已链接到）可以使用时间间隔，并且该配置由所有 JDBC 兼容的连接共享，MySQL 和 Postgres包括。
For incremental query modes that use timestamps, the source connector uses a configuration
timestamp.delay.interval.ms...
replication log? (i don't know how this works)
您可以找到 the Debezium guide here，但此机制与 Mongo、Postgres、MySQL、MSSQL、Oracle 等不同。