代码之家 › 专栏 › 技术社区 › Ryuzaki L

kafka连接器如何用于postgresql和mysql数据库

apache-kafka-connect postgresql mysql

-1

Ryuzaki L · 技术社区 · 7 年前

我将从这里开始学习快速入门教程 quick-start-kafka-connect

本教程演示如何将mysql数据库表更改流式传输到kafka主题中。

唯一的部分是下载所有内容并添加 /tmp/kafka-connect-jdbc-source.json

这在后台是如何工作的?

1:它是否在特定的时间间隔内创建与数据库和监视表的连接?或

3:mysql和postgresql的机制是一样的吗?

1 回复 | 直到 6 年前

OneCricketeer Gabriele Mariotti 7 年前

Debezium监控OpLog。

Kafka Connect JDBC ByConfluent(您已经链接到)可以使用一个时间间隔,并且该配置由所有符合JDBC的连接共享,包括MySQL和Postgres。

对于使用时间戳的增量查询模式,源连接器使用配置 timestamp.delay.interval.ms ...

复制日志?(我不知道这是怎么回事)

你可以找到 the Debezium guide here ,但这种机制对于Mongo、Postgres、MySQL、MSSQL、Oracle等不同。

推荐文章

Bard.Mus · 迁移后的数据库字符集环境

1 年前

tinkerr · 如何在2025年在MacOS上安装MySQL 5.7

1 年前

Efannnnnn · 将Id数据存储到任何页面

1 年前

yooooo · 用于在块中删除的存储过程-LOOP未执行

1 年前

archetypezero · Homebrew mysqld崩溃循环,启动时抛出“服务器退出而不更新PID文件”[重复]

1 年前

Topher Rhodes · 如何在MySQL中使用任意数量的多个标签过滤/限制所选帖子

1 年前

John Beasley · 更新一定数量记录的连续日期

1 年前

user3065579 · 如何从MySQL中为每个唯一用户选择唯一事件?[副本]

1 年前

ColinM · MySQL以前的结果查询返回不正确的值

1 年前

Sergey_Z · MySQL只需无条件连接2个表和交叉连接

1 年前