AI 에이전트의 경우: 문서 인덱스 https://www.mongodb.com/ko-kr/docs/llms.txt에서 확인할 수 있습니다 — 모든 URL 경로에 .md를 추가하면 모든 페이지의 마크다운 버전을 사용할 수 있습니다.
Make the MongoDB docs better! We value your opinion. Share your feedback for a chance to win $100.
MongoDB Branding Shape
Click here >
Docs Menu

시작 속성

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

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

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

이름
설명

startup.mode

유형: 문자열

설명:
사용 가능한 소스 오프셋이 없을 때 connector 시작하는 방법을 지정합니다.

startup.mode=latest변경 스트림

재개하려면 startup.mode=timestamp connector 소스 오프셋에서 가져오는 재개 토큰이 startup.mode.timestamp.* 필요합니다. 소스 오프셋을 사용할 수 없는 경우 connector 기존 소스 데이터 전체 또는 일부를 무시하거나 먼저 기존 소스 데이터를 모두 복사한 다음 새 데이터를 계속 처리 할 수 있습니다. timestamp latest인 경우 connector 기존의 모든 소스 데이터를 무시합니다.

인 경우 connector 속성을 작동합니다. 구성된 속성이 없는 경우 는 에 해당합니다. 인 경우 connector startup.mode=copy_existing 는 기존의 모든 소스 데이터를 변경 스트림 이벤트에 복사합니다. 이 설정은 더 이상 사용되지 않는 설정 와 copy.existing=true 동일합니다.

소스 커넥터가 데이터베이스의 기존 데이터를 변환하는 동안 시스템에서 데이터베이스의 데이터를 변경하는 경우, 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



유형:
문자열 설명: connector 가 데이터를 복사할 네임스페이스를 일치시키기 위해 사용하는 표현식 입니다. 네임스페이스 MongoDB database 이름과 컬렉션 마침표로 구분하여 설명합니다( databaseName.collectionName 예시:).

예시 들어, 다음 정규 표현식 설정은 데이터베이스 에서 'page'로 시작하는 컬렉션과 stats 일치합니다.

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

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

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

startup.mode.copy.existing.pipeline

유형: 문자열

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

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

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 설정하다 하면 connector 기존 집계 복사본에 임시 디스크 저장 사용합니다.

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

이 페이지의 내용