debezium/example-mysql

Debezium示例MySQL镜像文档

镜像概述与主要用途

Debezium示例MySQL镜像是Debezium项目提供的预配置MySQL服务器，内置简单的Inventory数据库，专门用于演示、教程和开发测试场景。该镜像旨在简化Debezium变更数据捕获（CDC）功能的学习与验证过程，用户可直接基于此镜像快速搭建演示环境，无需手动配置数据库结构和测试数据。

仓库地址：quay.io/debezium/example-mysql

核心功能与特性

核心功能

• 预配置Inventory数据库：包含完整的测试数据结构及示例数据，模拟实际业务场景中的数据变更。
• 即开即用的演示环境：无需手动初始化数据库，启动容器后自动加载Inventory数据库及表结构。
• 兼容Debezium连接器：针对Debezium的CDC功能优化，支持数据变更事件的捕获与流式传输。

关键特性

• 轻量级配置：基于官方MySQL镜像构建，保留原生MySQL功能，仅添加必要的演示数据。
• 标准化数据模型：Inventory数据库包含典型业务表（如customers、products、orders、order_items），结构清晰，便于理解数据变更流程。
• 支持主流MySQL客户端：可通过标准MySQL客户端（如mysql命令行工具、Navicat等）连接，验证数据及变更。

使用场景与适用范围

典型场景

• Debezium教程实践：作为Debezium官方教程的配套数据库，演示CDC功能端到端流程。
• CDC功能演示：向团队或用户展示如何通过Debezium捕获MySQL数据变更并发送至Kafka。
• 开发测试环境：在本地或CI/CD环境中快速搭建包含测试数据的MySQL实例，验证数据同步逻辑。

适用范围

• 技术演示与培训
• Debezium连接器开发测试
• 数据库变更事件处理逻辑验证
• 轻量级CDC原型验证

使用方法与配置说明

前提条件

• 已安装Docker Engine（20.10+推荐）
• 网络环境可访问quay.io镜像仓库

快速部署（Docker Run）

1. 拉取镜像

bash
docker pull quay.io/debezium/example-mysql:latest

2. 启动容器

bash
docker run -d \
  --name debezium-example-mysql \
  -p 3306:3306 \
  -e MYSQL_ROOT_PASSWORD=debezium \
  -e MYSQL_USER=debezium \
  -e MYSQL_PASSWORD=dbz \
  quay.io/debezium/example-mysql:latest

3. 验证部署

容器启动后，通过MySQL客户端连接验证：

bash
mysql -h localhost -P 3306 -u root -pdebezium

连接成功后，查看inventory数据库及表结构：

sql
USE inventory;
SHOW TABLES;
-- 应显示 customers, products, orders, order_items 表

Docker Compose部署（与Debezium集成示例）

创建docker-compose.yml文件，集成MySQL、ZooKeeper、Kafka及Debezium连接器（完整教程参考Debezium官方文档）：

yaml
version: '3.8'
services:
  zookeeper:
    image: quay.io/debezium/zookeeper:latest
    ports:
      - "2181:2181"
    environment:
      ZOOKEEPER_CLIENT_PORT: 2181
      ZOOKEEPER_TICK_TIME: 2000

  kafka:
    image: quay.io/debezium/kafka:latest
    ports:
      - "9092:9092"
    depends_on:
      - zookeeper
    environment:
      KAFKA_BROKER_ID: 1
      KAFKA_ZOOKEEPER_CONNECT: zookeeper:2181
      KAFKA_LISTENER_SECURITY_PROTOCOL_MAP: PLAINTEXT:PLAINTEXT,PLAINTEXT_HOST:PLAINTEXT
      KAFKA_ADVERTISED_LISTENERS: PLAINTEXT://kafka:29092,PLAINTEXT_HOST://localhost:9092
      KAFKA_OFFSETS_TOPIC_REPLICATION_FACTOR: 1

  mysql:
    image: quay.io/debezium/example-mysql:latest
    ports:
      - "3306:3306"
    environment:
      MYSQL_ROOT_PASSWORD: debezium
      MYSQL_USER: debezium
      MYSQL_PASSWORD: dbz
    volumes:
      - mysql-data:/var/lib/mysql

volumes:
  mysql-data:

启动服务栈：

bash
docker-compose up -d

核心配置参数（环境变量）

数据模型说明（Inventory数据库）

inventory数据库包含以下核心表及示例数据：

许可证信息

• 镜像构建文件（Dockerfiles、脚本等）：MIT License
• 镜像内软件（含MySQL、Debezium组件等）：Apache License 2.0 及其他开源许可证（详见镜像仓库说明）

相关资源

• Debezium官方教程
• https://github.com/debezium/debezium
• https://hub.docker.com/_/mysql
• Debezium社区支持