기존 Kafka Cluster로 설치
Relational Migrator는 Kafka Connect를 포함한 기존 Kafka cluster에 설치할 수 있습니다. 이 설치 방법은 이미 Kafka를 실행 중이거나 Kafka 설치 및 구성에 대한 고유한 접근 방식이 있는 경우에 적합합니다.
시작하기 전에
Relational Migrator를 실행하는 컴퓨터에서 Kafka Connect 클러스터에 대한 Kafka 및 네트워크 연결이 있어야 합니다.
단계
Debezium 소스 연결 플러그인 설치
소스 데이터베이스에 대한 소스 커넥터 아카이브를 다운로드합니다.
아카이브의 압축을 풉니다.
debezium-connector.jar파일을debezium-connector디렉토리에 복사합니다.debezium-connector.jar다운로드한debezium-connector-xxx아카이브에서 파일을 Kafka Connect의 plugin.path 에 있는 디렉토리로 복사합니다. Kafka Connect 클러스터에서. 예:/kafka/connect/debezium-connector-sqlserver.Kafka Connect 클러스터를 다시 시작합니다.
플러그인이 성공적으로 등록되면
kafka-connect시작 로그에 다음 로그 문이 나타납니다.INFO || Added plugin 'io.debezium.connector.sqlserver.SqlServerConnector'
Relational Migrator Sink Connect 플러그인 설치
kafka-connect-migrator.jar파일의 최신 버전을 다운로드합니다.최신
kafka-connect-migrator.jar파일을 다운로드하려면 Migrator 설치 프로그램 리포지토리를 참조하세요..jar파일을kafka-connect-migrator디렉토리에 복사합니다.새
kafka-connect-migrator디렉토리는 Kafka Connect의 plugin.path 에서 찾을 수 있습니다. . 예:/kafka/connect/kafka-connect-migrator.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 파일 위치를 참조하세요.
속성 이름 | 기본값 | 설명 |
|---|---|---|
spring.profiles.active | 로컬 | Relational Migrator는 다음 프로필에서 실행할 수 있습니다.
프로필 값을 |
server.port | 8278 | Relation Migrator 애플리케이션이 실행되는 포트입니다. |
migrator.kafka.bootstrap.servers | 기본값 없음 | 이는 기존 kafka cluster의 |
migrator.kafka.connect.url | 기본값 없음 | {host}:{port} 형식을 사용하는 Kafka Connect 호스트 URL입니다. |
migrator.kafka.connect.metrics.jmx.service.url | 기본값 없음 | Kafka Connect JMX(Java 관리 확장 프로그램) URL입니다. 예를 들면 다음과 같습니다. |
성공적인 설치 확인
Relational Migrator를 시작하고 로그를 확인합니다. Kafka 프로필이 활성 상태이고 오류가 없는지 확인합니다.
log 파일은 OS 특정 위치에 있습니다. 자세한 내용은 Relational Migrator 파일 위치를 참조하세요.