我正在学习这里的快速入门教程,快速启动卡夫卡连接
本教程演示如何将mysql数据库表更改为kafka主题。
唯一的部分是下载所有内容,然后添加带有一些配置属性的/tmp/kafka-connect-jdbc-source.json文件并启动。
背景下是如何工作的?
1:它是否在特定时间间隔内建立与数据库和监视表的连接?或 2:它是否使用复制日志?(我不知道这是怎么回事) 3: mysql和postgresql的机制是相同的吗?
发布于 2019-01-05 23:10:04
Debezium监视OpLog。
通过汇合(您已经链接到的) Kafka连接JDBC可以使用一个时间间隔,该配置由所有与JDBC兼容的连接共享,包括MySQL和Postgres。
对于使用时间戳的增量查询模式,源连接器使用配置
timestamp.delay.interval.ms.复制日志?(我不知道这是怎么回事)
您可以找到这里的Debezium指南,但是这种机制对于Mongo、Postgres、MySQL、MSSQL、Oracle等等不同。
https://stackoverflow.com/questions/53989801
复制相似问题