第 1 章 关于本教程
教程包括以下步骤:
- 使用简单示例数据库部署 MySQL 数据库服务器到 OpenShift。
- 在 Streams for Apache Kafka 中应用自定义资源,以自动构建包含 Debezium MySQL 连接器插件的 Kafka Connect 容器镜像。
- 创建 Debezium MySQL 连接器资源,以捕获数据库中的更改。
- 验证连接器部署。
- 查看连接器从数据库中发送到 Kafka 主题的更改事件。
先决条件
- 熟悉 OpenShift 和 Apache Kafka 的 Streams。
- 您可以访问安装了集群 Operator 的 OpenShift 集群。
- Apache Kafka Operator 的 Streams 正在运行。
- 部署了 Apache Kafka 集群,如 在 OpenShift 中部署和管理 Apache Kafka 的流 中所述。
- 您有一个红帽构建的 Debezium 许可证。
-
您知道如何使用 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。默认情况下,镜像流不可用。