AI 에이전트의 경우: 문서 인덱스는 https://www.mongodb.com/ko-kr/docs/llms.txt에서 사용할 수 있으며, 모든 페이지의 마크다운 버전은 어떤 URL 경로에 .md를 추가하여 사용할 수 있습니다.
Docs Menu

시작 속성

다음 구성 설정을 사용하여 MongoDB 컬렉션을 변경 스트림 이벤트로 변환하기 위한 MongoDB Kafka 소스 커넥터의 시작을 구성합니다.

팁

기존 데이터 복사 기능을 사용하는 예제는 기존 데이터 복사 사용 예제를 참조하세요.

범주별로 구성된 소스 커넥터 구성 설정 목록은 소스 커넥터 구성 속성 가이드를 참조하세요.

이름
설명

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

유형: 문자열

설명:
startup.mode=timestamp인 경우에만 작동합니다. 변경 스트림 의 시작 점 지정합니다.

변경 스트림 매개변수에 대해 자세히 학습 MongoDB 매뉴얼의 $changeStream ( 집계 )을 참조하세요.

기본값: ""
허용되는 값:

  • 에포크 이후의 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

유형: 문자열

설명:
기존 데이터를 복사할 때 connector 실행하는 파이프라인 작업의 인라인 배열 . 이 설정을 사용하여 소스 컬렉션 필터하다 하고 복사 프로세스 에서 인덱스 사용을 개선할 수 있습니다.

예시 들어, 다음 설정은 $match 집계 연산자 사용하여 값이 false인 closed 필드 포함된 문서만 복사하도록 connector 에 지시합니다.

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

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

startup.mode.copy.existing.max.threads

유형: int

설명:
connector 데이터를

복사하는 데 사용할 수 있는 최대
스레드 수입니다. 기본값: 환경에서 사용 가능한 프로세서 수 허용되는 값: 정수

startup.mode.copy.existing.queue.size

유형: int

설명:
connector 가 데이터를 복사할 때 사용할 수 있는 대기열의 크기입니다.

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

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

유형: 불리언

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

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

이 페이지 평가하기

이 페이지의 내용