第 2 章 启动服务
使用 Debezium 需要带有 Kafka 和 Kafka Connect 的 AMQ Streams、数据库和 Debezium 连接器服务。要运行本教程的服务,您必须:
2.1. 部署 MySQL 数据库 复制链接链接已复制到粘贴板!
复制链接链接已复制到粘贴板!
部署包含示例 inventory
数据库的 MySQL 数据库服务器,其中包含预填充数据的多个表。Debezium MySQL 连接器将捕获示例表中发生的更改,并将更改事件记录传输到 Apache Kafka 主题。
流程
运行以下命令来启动 MySQL 数据库,该命令启动一个配置了
示例清单
数据库的 MySQL 数据库服务器:oc new-app --name=mysql quay.io/debezium/example-mysql:latest
$ oc new-app --name=mysql quay.io/debezium/example-mysql:latest
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 运行以下命令来配置 MySQL 数据库的凭证,它会更新 MySQL 数据库的部署配置以添加用户名和密码:
oc set env dc/mysql MYSQL_ROOT_PASSWORD=debezium MYSQL_USER=mysqluser MYSQL_PASSWORD=mysqlpw
$ oc set env dc/mysql MYSQL_ROOT_PASSWORD=debezium MYSQL_USER=mysqluser MYSQL_PASSWORD=mysqlpw
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 通过调用以下命令来验证 MySQL 数据库是否正在运行,该命令后跟显示 MySQL 数据库正在运行且 pod 就绪的输出显示:
oc get pods -l app=mysql
$ oc get pods -l app=mysql NAME READY STATUS RESTARTS AGE mysql-1-2gzx5 1/1 Running 1 23s
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 打开一个新终端,再登录示例
inventory
数据库。此命令在运行 MySQL 数据库的 pod 中打开 MySQL 命令行客户端。客户端使用您之前配置的用户名和密码:
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 列出
inventory
数据库中的表:Copy to Clipboard Copied! Toggle word wrap Toggle overflow 浏览数据库并查看它所包含的数据,例如查看
客户
表:Copy to Clipboard Copied! Toggle word wrap Toggle overflow