시작 속성

startup.mode

유형: string

설명:
사용 가능한 소스 오프셋이 없을 때 커넥터를 시작하는 방법을 지정합니다. 변경 스트림을 재개하려면 커넥터가 소스 오프셋에서 가져오는 재개 토큰이 필요합니다. 소스 오프셋을 사용할 수 없는 경우 커넥터는 기존 소스 데이터 전체 또는 일부를 무시하거나 먼저 기존 소스 데이터를 모두 복사한 다음 새 데이터를 계속 처리할 수 있습니다.

startup.mode=latest인 경우, 커넥터는 기존의 모든 소스 데이터를 무시합니다.

startup.mode=timestamp인 경우 커넥터는 startup.mode.timestamp.* 속성을 작동합니다. 속성이 구성되지 않은 경우, timestamp 는 latest와 동일합니다.

startup.mode=copy_existing인 경우 커넥터가 기존의 모든 소스 데이터를 변경 스트림 이벤트에 복사합니다. 이 설정은 더 이상 사용되지 않는 설정 copy.existing=true과 동일합니다.

소스 connector 데이터베이스 의 기존 데이터를 변환하는 동안 시스템에서 데이터베이스의 데이터를 변경하는 경우, MongoDB 최신 변경 사항을 반영하기 위해 중복된 변경 스트림 이벤트를 생성할 수 있습니다. 데이터 복사가 의존하는 변경 스트림 이벤트는 멱등 있으므로 복사된 데이터는 궁극적으로 일관적인 되며 '최소 한 번' 전송 보장을 준수합니다.

기본값:latest
허용되는 값: latest, timestamp, copy_existing

startup.mode.timestamp.start.at.operation.time

Type: string

Description:
Actuated only if startup.mode=timestamp. Specifies the starting point for the change stream.

To learn more about Change Stream parameters, see $changeStream (aggregation) in the MongoDB manual.

Default: ""
Accepted Values:

• 에포크 이후의 10진수 정수형 초(예시: 30)입니다.

• 정밀도가 1초인 ISO-8601 형식의 순간(예시: 1970-01-01T00:00:30Z)입니다.

• 표준 확장 JSON(v2) 형식의 BSON 타임스탬프(예시: {"$timestamp": {"t": 30, "i": 0}})입니다.

startup.mode.copy.existing.namespace.regex

유형: string

설명:
커넥터가 데이터를 복사할 네임스페이스와 일치시키기 위해 사용하는 정규식입니다. 네임스페이스는 MongoDB 데이터베이스 이름과 컬렉션을 마침표로 구분하여 설명합니다(예시: databaseName.collectionName).

예시, 다음 정규 표현식 설정은 stats 데이터베이스에서 "페이지"로 시작하는 컬렉션과 일치합니다:

startup.mode.copy.existing.namespace.regex=stats\.page.*

위 예시의 \ 문자는 정규 표현식에서 그 뒤에 오는 . 문자를 이스케이프합니다. 정규식을 빌드하는 방법에 대한 자세한 내용은 Java API 문서의 패턴을 참조하세요.

기본값: ""
허용되는 값: 유효한 정규 표현식

startup.mode.copy.existing.pipeline

Type: string

Description:
An inline array of pipeline operations the connector runs when copying existing data. You can use this setting to filter the source collection and improve the use of indexes in the copying process.

For example, the following setting uses the $match aggregation operator to instruct the connector to copy only documents that contain a closed field with a value of false.

startup.mode.copy.existing.pipeline=[ { "$match": { "closed": "false" } } ]

기본값: ""
허용되는 값: 유효한 집계 파이프라인 단계

startup.mode.copy.existing.max.threads

유형: int

설명:
커넥터가 데이터를 복사하는 데 사용할 수 있는 최대 스레드 수입니다.

기본값: 환경에서 사용 가능한 프로세서 수
허용되는 값: 정수

startup.mode.copy.existing.queue.size

유형: int

설명:
커넥터가 데이터를 복사할 때 사용할 수 있는 큐의 크기입니다.

기본값: 16000
허용되는 값: 정수

startup.mode.copy.existing.allow.disk.use

유형: 불리언

설명:
true으(로) 설정하면, 커넥터는 이미 있는 집계를 복사하기 위해 임시 디스크 저장소를 사용합니다.

기본값: true
허용되는 값: true 또는 false