3장. 서비스 시작


Debezium을 사용하려면 Kafka 및 Kafka Connect, 데이터베이스 및 Debezium 커넥터 서비스가 포함된 AMQ Streams가 필요합니다. 이 튜토리얼에 대한 서비스를 실행하려면 다음을 수행해야 합니다.

3.1. MySQL 데이터베이스 배포

데이터로 미리 채워진 여러 테이블을 포함하는 예제 inventory 데이터베이스를 포함하는 MySQL 데이터베이스 서버를 배포합니다. Debezium MySQL 커넥터는 샘플 테이블에서 발생하는 변경 사항을 캡처하고 변경 이벤트 레코드를 Apache Kafka 주제로 전송합니다.

프로세스

  1. 예제 inventory 데이터베이스로 구성된 MySQL 데이터베이스 서버를 시작하는 다음 명령을 실행하여 MySQL 데이터베이스를 시작합니다.

    $ oc new-app -l app=mysql --name=mysql quay.io/debezium/example-mysql:latest
  2. 사용자 이름과 암호를 추가하도록 MySQL 데이터베이스의 배포 구성을 업데이트하는 다음 명령을 실행하여 MySQL 데이터베이스의 자격 증명을 구성합니다.

    $ oc set env deployment/mysql MYSQL_ROOT_PASSWORD=debezium MYSQL_USER=mysqluser MYSQL_PASSWORD=mysqlpw
  3. 다음 명령을 호출하여 MySQL 데이터베이스가 실행 중인지 확인합니다. 그 뒤에 MySQL 데이터베이스가 실행 중이고 포드가 준비되었는지 확인합니다.

    $ oc get pods -l app=mysql
    NAME            READY   STATUS    RESTARTS   AGE
    mysql-1-2gzx5   1/1     Running   1          23s
  4. 새 터미널을 열고 샘플 인벤토리 데이터베이스에 로그인합니다.

    이 명령은 MySQL 데이터베이스를 실행 중인 포드에서 MySQL 명령줄 클라이언트를 엽니다. 클라이언트는 이전에 구성한 사용자 이름과 암호를 사용합니다.

    $ oc exec mysql-1-2gzx5 -it -- mysql -u mysqluser -pmysqlpw inventory
    mysql: [Warning] Using a password on the command line interface can be insecure.
    Reading table information for completion of table and column names
    You can turn off this feature to get a quicker startup with -A
    
    Welcome to the MySQL monitor.  Commands end with ; or \g.
    Your MySQL connection id is 7
    Server version: 5.7.29-log MySQL Community Server (GPL)
    
    Copyright (c) 2000, 2020, Oracle and/or its affiliates. All rights reserved.
    
    Oracle is a registered trademark of Oracle Corporation and/or its
    affiliates. Other names may be trademarks of their respective
    owners.
    
    Type 'help;' or '\h' for help. Type '\c' to clear the current input statement.
    
    mysql>
  5. inventory 데이터베이스의 테이블을 나열합니다.

    mysql> show tables;
    +---------------------+
    | Tables_in_inventory |
    +---------------------+
    | addresses           |
    | customers           |
    | geom                |
    | orders              |
    | products            |
    | products_on_hand    |
    +---------------------+
    6 rows in set (0.00 sec)
  6. 데이터베이스를 살펴보고 포함된 데이터를 확인합니다. 예를 들어 customers 테이블을 확인합니다.

    mysql> select * from customers;
    +------+------------+-----------+-----------------------+
    | id   | first_name | last_name | email                 |
    +------+------------+-----------+-----------------------+
    | 1001 | Sally      | Thomas    | sally.thomas@acme.com |
    | 1002 | George     | Bailey    | gbailey@foobar.com    |
    | 1003 | Edward     | Walker    | ed@walker.com         |
    | 1004 | Anne       | Kretchmar | annek@noanswer.org    |
    +------+------------+-----------+-----------------------+
    4 rows in set (0.00 sec)
Red Hat logoGithubRedditYoutubeTwitter

자세한 정보

평가판, 구매 및 판매

커뮤니티

Red Hat 문서 정보

Red Hat을 사용하는 고객은 신뢰할 수 있는 콘텐츠가 포함된 제품과 서비스를 통해 혁신하고 목표를 달성할 수 있습니다.

보다 포괄적 수용을 위한 오픈 소스 용어 교체

Red Hat은 코드, 문서, 웹 속성에서 문제가 있는 언어를 교체하기 위해 최선을 다하고 있습니다. 자세한 내용은 다음을 참조하세요.Red Hat 블로그.

Red Hat 소개

Red Hat은 기업이 핵심 데이터 센터에서 네트워크 에지에 이르기까지 플랫폼과 환경 전반에서 더 쉽게 작업할 수 있도록 강화된 솔루션을 제공합니다.

© 2024 Red Hat, Inc.