기존 Kafka Cluster로 설치

Debezium 소스 연결 플러그인 설치

1. 소스 데이터베이스 에 대한 소스 connector 아카이브를 다운로드합니다.

   • MySQL connector 플러그인 아카이브

   • Postgres connector 플러그인 아카이브

   • SQL MongoDB Server connector 플러그인 아카이브

   • Oracle connector 플러그인 아카이브

2. 아카이브의 압축을 풉니다.

3. debezium-connector.jar 파일 을 debezium-connector 디렉토리 에 복사합니다.

   debezium-connector.jar 다운로드한 debezium-connector-xxx 아카이브에서 파일을 Kafka Connect의 plugin.path 에 있는 디렉토리로 복사합니다. Kafka Connect 클러스터에서. 예: /kafka/connect/debezium-connector-sqlserver.

4. Kafka Connect 클러스터 를 다시 시작합니다.

   플러그인이 성공적으로 등록되면 kafka-connect 시작 로그에 다음 로그 성명서 이 나타납니다.

   INFO || Added plugin 'io.debezium.connector.sqlserver.SqlServerConnector'

Relational Migrator Sink Connect 플러그인 설치

1. kafka-connect-migrator.jar 파일 의 최신 버전을 다운로드합니다.

   최신 kafka-connect-migrator.jar 파일을 다운로드하려면 Migrator 설치 프로그램 리포지토리를 참조하세요.

2. .jar 파일을 kafka-connect-migrator 디렉토리에 복사합니다.

   새 kafka-connect-migrator 디렉토리는 Kafka Connect의 plugin.path 에서 찾을 수 있습니다. . 예: /kafka/connect/kafka-connect-migrator.

3. Kafka Connect 클러스터 를 다시 시작합니다.

   플러그인이 성공적으로 등록되면 kafka-connect 시작 로그에 다음 로그 성명서 이 나타납니다.

   INFO || Added plugin 'com.mongodb.migrator.kafka.connect.MigratorSinkConnector'

Relational Migrator 설치

다운로드 센터 에서 최신 버전의 Relational Migrator 설치 프로그램을 선택합니다.

kafka 통합 모드에서 Relational Migrator 실행

kafka-integrated 모드에서 실행하려면 user.properties 파일에서 다음 구성을 업데이트합니다.

user.properties 파일 은 OS 특정 위치 에 있습니다. 자세한 내용은 Relational Migrator 파일 위치를 참조하세요.

성공적인 설치 확인

Relational Migrator를 시작하고 로그를 확인합니다. Kafka 프로필이 활성 상태이고 오류가 없는지 확인합니다.

log 파일 은 OS 특정 위치 에 있습니다. 자세한 내용은 Relational Migrator 파일 위치를 참조하세요.