기존 속성 복사
개요
중요
copy.existing* 속성은 더 이상 사용되지 않습니다.
MongoDB Kafka Connector의 버전 1.9 부터 copy.existing* 속성은 더 이상 사용되지 않으며 향후 릴리스에서 제거될 수 있습니다. 기존 복사 기능을 구성하려면 startup.mode* 속성을 사용해야 합니다. startup.mode* 설정에 대해 자세히 알아보려면 시작 속성을 참조하세요.
다음 구성 설정을 사용하여 MongoDB collection을 change stream 이벤트로 변환하는 기존 복사 기능을 활성화합니다.
범주별로 구성된 소스 커넥터 구성 설정 목록은 소스 커넥터 구성 속성 가이드를 참조하세요.
설정
이름 | 설명 | |
|---|---|---|
copy.existing | Type: boolean Description: Whether to enable the copy existing feature which converts all
data in a MongoDB collection to Change Stream events and
publishes them on Kafka topics. If MongoDB changes the source
collection data after the connector starts the copy process, the
connector creates events for the changes after it completes the copy
process. 소스 커넥터가 데이터베이스의 기존 데이터를 변환하는 동안 시스템에서 데이터베이스의 데이터를 변경하는 경우, MongoDB는 최신 변경 사항을 반영하기 위해 중복된 변경 스트림 이벤트를 생성할 수 있습니다. 데이터 복사가 의존하는 변경 스트림 이벤트는 멱등성이 있으므로 복사된 데이터는 결국 일관성을 갖습니다. Default: falseAccepted Values: true or false | |
copy.existing.namespace.regex | Type: string Description: Regular expression the connector uses to match namespaces from
which to copy data. A namespace describes the MongoDB database name
and collection separated by a period (for example, databaseName.collectionName).예시다음 예시에서 표현식 설정은 위 예제의 "" 문자는 "." 정규 표현식에서 뒤에 오는 문자입니다. 정규 표현식을 빌드하는 방법에 대한 자세한 내용은 패턴에 대한 Java API 문서를 참조하세요. Default: ""Accepted Values: A valid regular expression | |
copy.existing.pipeline | Type: string Description: An 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. 예시다음 예에서는 $match 애그리게이션 연산자를 사용하여 값이 Default: []Accepted Values: Valid aggregation pipeline stages | |
copy.existing.max.threads | Type: int Description: The maximum number of threads the connector can use to copy data. Default: number of processors available in the environment Accepted Values: An integer | |
copy.existing.queue.size | Type: int Description: The size of the queue the connector can use when copying data. Default: 16000Accepted Values: An integer | |
copy.existing.allow.disk.use | Type: boolean Description: When set to true, the connector uses temporary disk storage
for the copy existing aggregation.Default: true |