前言


本教程演示了如何使用 Debezium 在 MySQL 数据库中捕获更新。随着数据库中的数据变化,您可以看到生成的事件流。

教程包括以下步骤:

  • 使用简单的示例数据库部署到 OpenShift,部署 MySQL 数据库服务器。
  • 在 AMQ Streams 中应用自定义资源,以自动构建包含 Debezium MySQL 连接器插件的 Kafka Connect 容器镜像。
  • 创建 Debezium MySQL 连接器资源,以捕获数据库中的更改。
  • 验证连接器部署。
  • 查看连接器从数据库发出到 Kafka 主题的更改事件。

前提条件

  • 熟悉 OpenShift 和 AMQ Streams。
  • 您可以访问安装集群 Operator 的 OpenShift 集群。
  • AMQ Streams Operator 正在运行。
  • OpenShift 上部署了 Apache Kafka 集群,如部署和升级 AMQ Streams 中所述。
  • 您有一个 Red Hat Integration 许可证。
  • 您将了解如何使用 OpenShift 管理工具。已安装 OpenShift oc CLI 客户端,或您可以访问 OpenShift Container Platform Web 控制台。
  • 根据您要存储 Kafka Connect 构建镜像的方式,您必须有访问容器 registry 的权限,或者您必须在 OpenShift 中创建 ImageStream 资源:

    将构建镜像存储在镜像 registry 中,如 Red Hat Quay.io 或 Docker Hub
    • 在 registry 中创建和管理镜像的帐户和权限。
    将构建镜像存储为原生 OpenShift ImageStream
    • ImageStream 资源部署到集群中。您必须为集群明确创建 ImageStream。默认情况下,镜像流不可用。

使开源包含更多

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。我们从这四个术语开始:master、slave、黑名单和白名单。由于此项工作十分艰巨,这些更改将在即将推出的几个发行版本中逐步实施。有关更多详情,请参阅我们的首席技术官 Chris Wright 提供的消息

Red Hat logoGithubRedditYoutubeTwitter

学习

尝试、购买和销售

社区

关于红帽文档

通过我们的产品和服务,以及可以信赖的内容,帮助红帽用户创新并实现他们的目标。

让开源更具包容性

红帽致力于替换我们的代码、文档和 Web 属性中存在问题的语言。欲了解更多详情,请参阅红帽博客.

關於紅帽

我们提供强化的解决方案,使企业能够更轻松地跨平台和环境(从核心数据中心到网络边缘)工作。

© 2024 Red Hat, Inc.