debezium install

📡 Debezium 설치

📦 1. Debezium Connector 다운로드

👉 Debezium 다운로드

• 사용할 버전 선택 (예: 3.4.0.Final)
• 아래 항목 다운로드: 👉 debezium-connector-mysql-3.4.0.Final-plugin.tar.gz
  💡 MySQL 기준 Connector (DB 종류에 따라 다름)

📁 2. 압축 해제

다운로드한 파일 압축 해제

tar -xvzf debezium-connector-mysql-3.4.0.Final-plugin.tar.gz

👉 폴더 형태로 생성됨 (여러 jar 포함)

📂 3. Kafka 라이브러리 경로에 복사

압축 해제한 폴더를 Kafka 경로에 복사

kafka/
 └── plugins/
     └── debezium-connector-mysql/

💡 기본적으로 Kafka Connect는 libs 경로의 플러그인을 자동 인식
(별도 plugin.path 설정 없이 사용 가능)

🧩 4. MySQL 드라이버 추가

👉 MySQL Connector/J 다운로드
ZIP 다운로드 후 .jar 추출

kafka/
 └── libs/
     └── mysql-connector-j-9.5.0.jar

⚙️ 5. Kafka Connect 설정 (Standalone)

파일: config/connect-standalone.properties

plugin.path=C:/kafka_2.13-4.1.1/plugins

🔍 동작 구조

MySQL → Debezium Connector → Kafka → Consumer

• Debezium → plugins에서 로드
• MySQL 드라이버 → libs에서 로드
• plugin.path → 플러그인 위치 지정

❗ 보충 (중요 개념)

• Standalone 모드

• 단일 서버 / 단일 프로세스
• 실습, 테스트용

• Distributed 모드

• 여러 워커로 구성
• 운영 환경