고급 Kafka 설정

사용자 속성

user.properties 파일 을 업데이트하여 선택적 구성 설정을 제공합니다.

spring.profiles.active

기본값: 로컬

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

• kafka: 내장된 서버 배포서버 를 사용하는 원격 서버 입니다.

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

server.port

기본값: 8278

Relational Migrator 애플리케이션 이 실행되는 포트입니다.

migrator.kafka.bootstrap.servers

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

예시: kafka-1:9092, kafka-2:9093.

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

migrator.kafka.connect.url

host:port 형식을 사용하는 Kafka Connect 호스팅하다 URL입니다.

예시: https://localhost:8083.

migrator.kafka.connect.metrics.jmx.service.url

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

migrator.kafka.connect.metrics.jmx.ssl

기본값: false

SSL이 활성화된 경우 true 로 설정합니다.

migrator.kafka.connect.metrics.jmx.properties 접두사를 붙여 SSL 구성을 위한 원격 JMX( Java Management Extensions)를 추가할 수 있습니다.

migrator.kafka.enable.topic.cleanup

기본값: false

마지막 마이그레이션 작업 중에 생성된 주제를 정리합니다.

migrator.connector.source.common.errors.max.retries

기본값: 5

소스 connector 의 경우 재시도 가능한 실패에 대한 최대 재시도 횟수를 지정합니다. Relational Migrator는 작업이 실패하기 전에 소스 데이터베이스 재시도 가능 실패로부터 설정된 제한까지 복구를 시도합니다.

migrator.connector.source.common.errors.retry.initial.max.ms

기본값: 30000 ms

소스 connector 의 경우 재시도 가능 실패 후 다시 시작될 때까지의 지연을 밀리초 단위로 지정합니다. 이 값은 재시도할 때마다 두 배로 증가하지만 migrator.connector.source.common.errors.retry.delay.max.ms 를 초과하지 않습니다.

migrator.connector.source.common.errors.retry.delay.max.ms

기본값: 60000 ms

소스 connector 의 경우 재시도 가능 실패 후 재시도 사이의 최대 지연 시간(밀리초)을 지정합니다.

migrator.connector.sink.common.errors.max.retries

기본값: 5

싱크 connector 의 경우 재시도 가능 오류에 대한 최대 재시도 횟수를 지정합니다. Relational Migrator는 작업이 실패하기 전에 소스 데이터베이스 재시도 가능 실패로부터 설정된 제한까지 복구를 시도합니다.

migrator.connector.sink.common.errors.retry.initial.max.ms

기본값: 30000 ms

싱크 connector 의 경우 재시도 가능 실패 후 다시 시작될 때까지의 지연을 밀리초 단위로 지정합니다. 이 값은 재시도할 때마다 두 배로 증가하지만 migrator.connector.sink.common.errors.retry.delay.max.ms 를 초과하지 않습니다.

migrator.connector.sink.common.errors.retry.delay.max.ms

기본값: 60000 ms

싱크 connector 의 경우 재시도 가능 실패 후 재시도 사이의 최대 지연 시간(밀리초)을 지정합니다.

스키마 레지스트리 속성

스키마 레지스트리에서 Relational Migrator 를 사용하려면 접두사가 migrator.connector.properties.common 인 user.properties 파일 에 속성을 추가합니다.

migrator.connector.properties.common.key.converter

기본값: migrator.connector.properties.common.key.converter

메시지 키의 변환기 클래스입니다.

migrator.connector.properties.common.value.converter

기본값: org.apache.kafka.connect.json.JsonConverter

메시지 값에 대한 변환기 클래스입니다.

migrator.connector.properties.common.key.converter.apicurio.registry.url

키 변환기를 위한 Apicurio 레지스트리의 URL 을 지정합니다.

http://{host}:{port} 또는 https://{host}:{port} 형식을 사용합니다.

migrator.connector.properties.common.value.converter.apicurio.registry.url

값 변환기를 위한 Apicurio 레지스트리의 URL 을 지정합니다.

http://{host}:{port} 또는 https://{host}:{port} 형식을 사용합니다.

소스 connector 속성

Relational Migrator 가 기본값 Debezium 소스 connector 속성을 설정합니다. 지원되는 각 소스 데이터베이스 에 대해 . connector 속성은 접두사 migrator.connector.source.common 를 사용하여 user.properties 파일 에 추가하여 재정의할 수 있습니다. 예를 예시 다음과 같습니다.

migrator.connector.source.common.errors.max.retries: 0

이 예시 에서 기본값 은 5이지만 이제 0으로 설정하다 되었습니다. 즉, 재시도 가능 실패 후 재시도할 수 없습니다.

싱크 Connector 속성

Relational Migrator 가 기본값 Migrator 싱크 connector 속성을 설정합니다. 지원되는 각 소스 데이터베이스 에 대해 . connector 속성은 접두사 migrator.connector.sink.common 를 사용하여 user.properties 파일 에 추가하여 재정의할 수 있습니다. 예를 예시 다음과 같습니다.

migrator.connector.sink.common.errors.max.retries: 0

이 예시 에서 기본값 은 5이지만 이제 0으로 설정하다 되었습니다. 즉, 재시도가 없습니다.