随着最近的 Debezium 发布,我们很高兴地宣布,除了现有的 MySQL 和 MongoDB 连接器之外,还添加了一个新的PostgreSQL 连接器

请务必阅读连接器文档,以深入了解不同的配置选项。

入门

最快体验新连接器的方法是使用Debezium 的 Postgres Docker 镜像,该镜像基于一个标准的 Postgres Docker 镜像,并在其上编译和安装 PostgreSQL逻辑解码插件,并设置必要的权限以便在本地(localhost)流式传输更改。

启动数据库服务器的 Docker 容器后,启动和配置连接器以从该服务器流式传输更改,其操作与Debezium 教程中详细描述的完全相同。唯一的明显区别是,您需要使用 PostgreSQL 服务器和 PostgreSQL 连接器配置参数,而不是 MySQL 服务器和 MySQL 连接器配置。

在您自己的环境中使用连接器

与 Mongo 和 MySQL 连接器不同,由于 PostgreSQL 连接器需要服务器端逻辑解码插件在 PostgreSQL 服务器中运行,因此将其启动和运行会更复杂一些。

总的来说,在您的环境中运行连接器涉及三个主要步骤:

  1. 编译并安装逻辑解码插件到您自己的服务器

  2. 为 PostgreSQL 服务器设置适当的复制权限

  3. 启动 Kafka Connect、Broker 和 Zookeeper 机器

对于步骤 1 和 2,您可以查看我们的PostgreSQL 容器镜像以及逻辑解码插件的源代码。

对于步骤 3,您可以使用 Debezium 的Kafka 容器镜像,或者在本地执行类似的设置。Debezium 教程连接器文档是帮助您完成此任务的绝佳资源。

Horia Chiorean

Horia 是 Red Hat 的一名开源软件开发人员,积极参与 Debezium 和 ModeShape 等项目。

   


关于 Debezium

Debezium 是一个开源的分布式平台,可以将现有数据库转变为事件流,使应用程序能够几乎即时地看到并响应数据库中已提交的每个行级更改。Debezium 构建在 Kafka 之上,并提供了 Kafka Connect 兼容的连接器,用于监控特定的数据库管理系统。Debezium 将数据更改的历史记录在 Kafka 日志中,这样您的应用程序可以随时停止和重新启动,并可以轻松地消费在未运行时错过的所有事件,确保所有事件都被正确且完整地处理。Debezium 在 Apache 许可证 2.0 下是 开源 的。

参与进来

我们希望您觉得 Debezium 有趣且有用,并希望尝试一下。在 Twitter @debezium 上关注我们,在 Zulip 上与我们聊天,或加入我们的 邮件列表 与社区交流。所有代码都在 GitHub 上开源,因此请在本地构建代码,帮助我们改进现有连接器并添加更多连接器。如果您发现问题或有改进 Debezium 的想法,请告诉我们或 记录一个问题

版权所有 © Debezium 及其作者。保留所有权利。有关我们的商标详情,请访问我们的 商标政策商标列表。第三方商标属于其各自所有者,在此提及并不表示任何认可或关联。
×