第 3 章 启动服务
使用 Debezium 需要 Kafka 和 Kafka Connect、数据库和 Debezium 连接器服务的 AMQ Streams。要为本教程运行服务,您必须:
3.1. 部署 MySQL 数据库 复制链接链接已复制到粘贴板!
部署 MySQL 数据库服务器,其中包含带有数据预先填充的多个表的示例 inventory
数据库。Debezium MySQL 连接器将捕获示例表中发生的更改,并将更改事件记录传送到 Apache Kafka 主题。
流程
运行以下命令启动 MySQL 数据库,该命令启动配置了示例
inventory
数据库的 MySQL 数据库服务器:oc new-app -l app=mysql --name=mysql quay.io/debezium/example-mysql:latest
$ oc new-app -l app=mysql --name=mysql quay.io/debezium/example-mysql:latest
Copy to Clipboard Copied! Toggle word wrap Toggle overflow 运行以下命令,为 MySQL 数据库配置凭证,该命令更新 MySQL 数据库的部署配置以添加用户名和密码:
oc set env deployment/mysql MYSQL_ROOT_PASSWORD=debezium MYSQL_USER=mysqluser MYSQL_PASSWORD=mysqlpw
$ oc set env deployment/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 探索数据库并查看其包含的数据,例如,查看
customers
表:Copy to Clipboard Copied! Toggle word wrap Toggle overflow