Docker를 통해 Kafka Connect 테스트를 위한 DB를 생성해보자.
Docker 설치
$ docker -v
Docker version 19.03.13, build 4484c46d9d
https://www.docker.com/products/docker-desktop 에 접속하여 OS에 맞는 Docker를 다운로드하여 설치한다.
설치 후 명령어를 통해 버전을 출력해보자.
MySQL Docker 이미지 다운로드
$ docker pull mysql
Using default tag: latest
latest: Pulling from library/mysql
bb79b6b2107f: Pull complete
49e22f6fb9f7: Pull complete
842b1255668c: Pull complete
9f48d1f43000: Pull complete
c693f0615bce: Pull complete
8a621b9dbed2: Pull complete
0807d32aef13: Pull complete
a56aca0feb17: Pull complete
de9d45fd0f07: Pull complete
1d68a49161cc: Pull complete
d16d318b774e: Pull complete
49e112c55976: Pull complete
Digest: sha256:8c17271df53ee3b843d6e16d46cff13f22c9c04d6982eb15a9a47bd5c9ac7e2d
Status: Downloaded newer image for mysql:latest
docker.io/library/mysql:latest
MySQL Docker 이미지를 다운로드한다. 태그에 버전을 지정하지 않으면 최신 버전을 다운로드한다.
MySQL Docker 컨테이너 생성 및 실행
$ docker run --name mysql-container -e MYSQL_ROOT_PASSWORD=비밀번호 -d -p 3306:3306 mysql:latest
# 컨테이너 리스트 출력
$ docker ps -a
# MySQL Docker 컨테이너 중지
$ docker stop mysql-container
# MySQL Docker 컨테이너 시작
$ docker start mysql-container
# MySQL Docker 컨테이너 재시작
$ docker restart mysql-container
mysql-container 라는 컨테이너를 생성하고 root 패스워드를 입력한다.
위 명령어로 컨테이너 리스트 출력과 재시작이 가능하다.
$ docker exec -it mysql-container bash
root@9988dc4e0dac:/# mysql -u root -p
Enter password:
Welcome to the MySQL monitor. Commands end with ; or \g.
Your MySQL connection id is 9
Server version: 8.0.28 MySQL Community Server - GPL
Copyright (c) 2000, 2022, Oracle and/or its affiliates.
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.
$ show databases;
| Database |
+--------------------+
| information_schema |
| mysql |
| performance_schema |
| sys |
+--------------------+
4 rows in set (0.01 sec)
mysql-container를 실행한 뒤 root로 접속한다.
show databases; 명령어로 생성된 database를 확인할 수 있다.
$ CREATE DATABASE kafka_test;
Query OK, 1 row affected (0.04 sec)
$ show databases;
+--------------------+
| Database |
+--------------------+
| information_schema |
| kafka_test |
| mysql |
| performance_schema |
| sys |
+--------------------+
5 rows in set (0.00 sec)
$ use kafka_test;
Database changed
Kafka Connect 테스트를 위한 kafka_test DB 생성이 완료 되었다.
출처
'개발 > Kafka' 카테고리의 다른 글
[Kafka] Managing Platform (0) | 2022.02.23 |
---|---|
[Kafka] JDBC Connector 옵션 테스트 (2) | 2022.02.10 |
[Kafka] Sink Connector 생성 (0) | 2022.02.08 |
[Kafka] Source Connector 생성 (0) | 2022.02.07 |
[Kafka] Kafka Connect 세팅 (0) | 2022.02.03 |