Docs Menu
Docs Home
/
Relational Migrator
/ /

기존 Kafka Cluster로 설치

이 페이지의 내용

  • 시작하기 전에
  • 단계
  • 다음 단계
  • 자세히 알아보기

Relational Migrator는 Kafka Connect를 포함한 기존 Kafka cluster에 설치할 수 있습니다. 이 설치 방법은 이미 Kafka를 실행 중이거나 Kafka 설치 및 구성에 대한 고유한 접근 방식이 있는 경우에 적합합니다.

Relational Migrator를 실행하는 컴퓨터에서 Kafka Connect 클러스터에 대한 Kafka 및 네트워크 연결이 있어야 합니다.

1
  1. 소스 데이터베이스 에 대한 소스 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'
2
  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'
3

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

4

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

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

속성 이름
기본값
설명
spring.profiles.active
로컬

Relational Migrator 는 다음 프로필에서 실행 수 있습니다.

  • kafka: 임베디드 서버 배포를 사용하는 원격 서버입니다.

  • confluent: managed Kafka 에 Confluent Cloud를 사용하는 원격 서버

프로필 값을 kafka 으로 설정합니다.

server.port
8278
Relation Migrator 애플리케이션이 실행되는 포트입니다.
migrator.kafka.bootstrap.servers
기본값 없음

이는 기존 Kafka 클러스터 의 host:port 쌍 목록입니다.

자세한 내용은 작업자 구성 속성을 참조하세요.

migrator.kafka.connect.url
기본값 없음
{host}:{port} 형식을 사용하는 Kafka Connect 호스팅하다 URL입니다.
migrator.kafka.connect.metrics.jmx.service.url
기본값 없음

Kafka Connect JMX(Java 관리 확장 프로그램) URL입니다.

예를 들면 다음과 같습니다. service:jmx:rmi:///jndi/rmi://localhost:9876/jmxrmi

5

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

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

돌아가기

Kafka 와 통합