3장. 서비스 시작
Debezium을 사용하려면 Kafka 및 Kafka Connect, 데이터베이스 및 Debezium 커넥터 서비스가 포함된 AMQ Streams가 필요합니다. 이 튜토리얼에 대한 서비스를 실행하려면 다음을 수행해야 합니다.
3.1. MySQL 데이터베이스 배포 링크 복사링크가 클립보드에 복사되었습니다!
데이터로 미리 채워진 여러 테이블을 포함하는 예제 inventory
데이터베이스를 포함하는 MySQL 데이터베이스 서버를 배포합니다. Debezium MySQL 커넥터는 샘플 테이블에서 발생하는 변경 사항을 캡처하고 변경 이벤트 레코드를 Apache Kafka 주제로 전송합니다.
프로세스
예제
inventory
데이터베이스로 구성된 MySQL 데이터베이스 서버를 시작하는 다음 명령을 실행하여 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 데이터베이스가 실행 중이고 포드가 준비되었는지 확인합니다.
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 새 터미널을 열고 샘플
인벤토리
데이터베이스에 로그인합니다.이 명령은 MySQL 데이터베이스를 실행 중인 포드에서 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