Docs Menu
Docs Home
/
Relational Migrator
/ / /

자체 관리 Kafka 설정 가이드

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

중요

이 가이드 Kafka 에 익숙하다고 가정합니다. 이 설명서 및 MongoDB 지원팀에서는 Kafka 클러스터 설정, 구성 또는 관리에 대한 지원 제공하지 않습니다.

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

1
  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 클러스터 의 Kafka Connect의 plugin.path에 있는 디렉토리 에 복사합니다. 예시: /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

kafka

server.port

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

user.properties 파일에 대한 자세한 내용은 사용자 속성을 참조하세요.

5

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

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

성공적인 설치를 확인한 후 새 프로젝트를 만들 수 있습니다.

돌아가기

Kafka 배포

이 페이지의 내용