/ /

모든 싱크 커넥터 구성 속성

개요

이 페이지에서는 MongoDB Kafka connector에 사용 가능한 모든 속성을 볼 수 있습니다. 이 페이지는 다른 싱크 connector 구성 속성 속성 페이지의 내용을 복제합니다.

모든 connector 구성 속성 페이지의 목록을 보려면 connector 구성 속성 페이지를 참조하세요.

MongoDB 연결

다음 구성 설정을 사용하여 MongoDB Kafka 싱크 connector 가 MongoDB cluster 와 연결하고 통신하는 방법을 지정합니다.

MongoDB 연결 구성과 관련된 옵션만 보려면 MongoDB 연결 구성 속성 페이지를 참조하세요.

이름	설명
connection.uri	필수 사항 유형: 문자열 설명: MongoDB 인스턴스 또는 클러스터 에 연결할 MongoDB 연결 URI 문자열입니다. 자세한 내용은 MongoDB 에 연결 가이드 참조하세요. 중요한: `connection.uri` 설정에서 인증 자격 증명 노출되지 않도록 하려면 ConfigProvider 를 사용하고 적절한 구성 매개 변수를 설정하다. 기본값: `mongodb://localhost:27017` 허용되는 값: MongoDB 연결 URI 문자열
server.api.version	유형: 문자열 설명: MongoDB 서버 에서 사용할 Stable API 버전입니다. Stable API 및 이를 지원 서버 버전에 대한 자세한 내용은 Stable API MongoDB 서버 매뉴얼 가이드 참조하세요. 기본값: `""` 허용되는 값: 빈 문자열 또는 유효한 Stable API 버전
server.api.deprecationErrors	유형: 부울 설명: 로 설정하다 `true` 하면 connector 선언된 Stable API 버전에서 더 이상 사용되지 않는 MongoDB 인스턴스 에서 명령을 호출하면 예외가 발생합니다. 구성 옵션을 사용하여 API 버전을 설정하다 수 `server.api.version` 있습니다. Stable API 에 대한 자세한 내용은 Stable API 의 MongoDB 매뉴얼 항목을 참조하세요. 기본값: `false` 허용되는 값: `true` 또는 `false`
server.api.strict	유형: 부울 설명: 로 설정하다 `true` 하면 connector 선언된 Stable API 버전에 포함되지 않은 명령을 MongoDB 인스턴스 에서 호출하면 예외가 발생합니다. 구성 옵션을 사용하여 API 버전을 설정하다 수 `server.api.version` 있습니다. Stable API 에 대한 자세한 내용은 Stable API 의 MongoDB 매뉴얼 항목을 참조하세요. 기본값: `false` 허용되는 값: `true` 또는 `false`
csfle.enabled	유형: 부울 설명:(으)로 설정하다 `true` 하면 MongoDB 연결에 대해 CSFLE(클라이언트 측 필드 레벨 암호화 )를 활성화하는 플래그입니다. 기본값: `false` 허용되는 값: `true` 또는 `false`
csfle.key.vault. 네임스페이스	유형: 문자열 설명: 형식의 CSFLE용 Key Vault 네임스페이스 `database.collection`. `encryption.__keyVault` 예시:. `csfle.enabled` 이(가)(으)로 설정하다 경우 `true` 필수입니다. 기본값: `""` 허용되는 값: 형식의 유효한 MongoDB 네임스페이스 `database.collection`
csfle.local.master.key	유형: 64 96문자열 설명: 로컬 KMS 제공자 사용한 CSFLE용 기본 인코딩된 바이트 로컬 마스터 키입니다. connector 는 키를 사용하여 Key Vault에 저장된 데이터 암호화 키를 암호화하고 해독합니다.`csfle.enabled` `true`이(가)(으)로 설정하다 경우 필수입니다. 기본값: `""` 허용되는 값: Base64로 인코딩된 96바이트 문자열
csfle.schema.map	유형: 문자열 설명: CSFLE의 암호화 스키마 맵을 정의하는 JSON 문서 . 이렇게 하면 네임스페이스를 암호화할 필드와 사용할 암호화 알고리즘 및 키를 지정하는 JSON schema에 매핑됩니다. 기본값: `""` 허용되는 값: 유효한 JSON 문서
csfle.bypass. 쿼리.analysis	유형: 부울 설명: CSFLE에 대한 자동 쿼리 분석을 우회할지 여부를 나타내는 플래그입니다. 로 설정하다 `true` 하면 connector 스키마 맵 기반 자동 암호화 비활성화하며 명시적 암호화 사용해야 합니다. 로 설정하다 `false` 하면 connector 자동 암호화 활성화하지만 `mongocryptd` 또는 `crypt_shared` 라이브러리가 필요합니다. `true` 외부 종속성 피하기 위해 기본값은 입니다. 기본값: `true` 허용되는 값: `true` 또는 `false`

MongoDB 네임스페이스

다음 구성 설정을 사용하여 MongoDB Kafka connector가 데이터를 쓰는 MongoDB database 및 collection을 지정합니다. 기본 DefaultNamespaceMapper 를 사용하거나 사용자 지정 클래스를 지정할 수 있습니다.

커넥터가 데이터를 쓰는 위치 지정과 관련된 옵션만 보려면 MongoDB 네임스페이스 매핑 구성 속성 페이지를 참조하세요.

이름

설명

namespace.mapper

유형: 문자열

설명:
데이터를 싱크할 데이터베이스 또는 컬렉션 지정하는 클래스의 정규화된 클래스 이름입니다.DefaultNamespaceMapper 기본값 database 는 및 collection 속성에 지정된 값을 사용합니다.

connector 이라는
데이터베이스 및 컬렉션 지정하기 위한 대체 클래스가 포함되어 있습니다. 자세한 내용은 FieldPathNamespaceMapper
FieldPathNamespaceMapper 설정을
참조하세요.

기본값:

com.mongodb.kafka.connect.sink.namespace.mapping.DefaultNamespaceMapper

허용되는 값: NamespaceMapper 인터페이스를 구현하는 클래스의 정규화된 Java 클래스 이름입니다.

database

필수 사항

유형: 문자열

설명:
싱크 connector 기록하는 MongoDB database 의 이름입니다.

허용되는 값: MongoDB database 이름

컬렉션

유형: 문자열

설명:
싱크 connector 기록하는 MongoDB 컬렉션 의 이름입니다. 싱크 connector 여러 주제를 따르는 경우 달리 지정되지 않은 모든 쓰기에 대한 기본값 컬렉션 입니다.

기본값: 주제 이름입니다.

허용되는 값: MongoDB collection 이름

FieldPathNamespaceMapper 설정

FieldPathNamespaceMapper 을 사용하도록 connector를 구성하는 경우 데이터의 필드 값을 기반으로 document를 싱크할 데이터베이스 및 collection을 지정할 수 있습니다.

이 매핑 동작을 사용하려면 아래와 같이 싱크 connector namespace.mapper 구성 속성을 정규화된 클래스 이름으로 설정합니다.

namespace.mapper=com.mongodb.kafka.connect.sink.namespace.mapping.FieldPathNamespaceMapper

FieldPathNamespaceMapper 에서는 다음 설정을 지정해야 합니다.

데이터베이스 및 collection에 대한 매핑 속성 중 하나 또는 둘 다
데이터베이스에 대한 key 또는 value 매핑 중 하나
collection에 대한 key 또는 value 매핑 중 하나입니다.

다음 설정을 사용하여 FieldPathNamespaceMapper 의 동작을 사용자 지정할 수 있습니다.

이름	설명
namespace.mapper.key.database.field	유형: 문자열 설명: 쓰기 (write) 데이터베이스 의 이름을 지정하는 키 문서 필드 의 이름입니다.
namespace.mapper.key.collection.field	유형: 문자열 설명: 쓰기 (write) 컬렉션 의 이름을 지정하는 키 문서 필드 의 이름입니다.
namespace.mapper.value.database.field	유형: 문자열 설명: 쓰기 (write) 데이터베이스 의 이름을 지정하는 값 문서 필드 의 이름입니다.
namespace.mapper.value.collection.field	유형: 문자열 설명: 쓰기 (write) 컬렉션 의 이름을 지정하는 값 문서 필드 의 이름입니다.
namespace.mapper.error.if.invalid	유형: 부울 설명: 문서 매핑된 필드 누락되었거나 잘못된 BSON 유형이 있는 경우 예외를 발생시킬지 여부입니다. 로 설정하다 하면 `true` connector 매핑된 필드 누락되었거나 잘못된 BSON 유형이 포함된 문서를 프로세스 하지 않습니다. connector 는 관련 오류 처리 구성 설정에 따라 처리 중지하거나 건너뛸 수 있습니다. 로 설정하다 `false` 하면 문서 매핑된 필드 누락되었거나 잘못된 BSON 유형이 있는 `database` 경우 connector `collection` 기본적으로 지정된 및 설정에 기록합니다. 기본값: `false` 허용되는 값: `true` 또는 `false`

커넥터 주제

다음 구성 설정을 사용하여 MongoDB Kafka sink connector가 데이터를 감시해야 하는 Kafka 주제를 지정합니다.

Kafka 주제 지정과 관련된 옵션만 보려면 싱크 커넥터의 Kafka 주제 속성 페이지를 참조하세요.

이름

설명

주제

필수 사항

유형: list

설명:
싱크 connector 감시하는 Kafka 주제 목록입니다.

topics 또는 topics.regex 설정 중 하나를 정의할 수 있지만 둘 다 정의할 수는 없습니다.

허용되는 값: 쉼표로 구분된 유효한 Kafka 주제 목록

topic.regex

필수 사항

유형:
문자열 설명: 싱크 connector 감시하는 Kafka 주제와 일치하는 표현식 입니다.

예를 예시, 다음 정규식은 "activity.landing.Clicks" 와 같은 주제 이름과 일치합니다. 및 '활동. 지원.클릭'. 주제 이름 'Activity.landing.views'와(과) 일치하지 않습니다. 및 'activity.Clicks'.

topics.regex=activity\\.\\w+\\.clicks$

topics 또는 topics.regex 설정 중 하나를 정의할 수 있지만 둘 다 정의할 수는 없습니다.

허용되는 값: java.util.regex.Pattern 을(를) 사용하는 유효한 정규 표현식 패턴입니다.

커넥터 메시지 처리

이 페이지의 설정을 사용하여 다음을 포함하여 MongoDB Kafka connector의 메시지 처리 동작을 구성합니다.

메시지 배치 크기
속도 제한
병렬 작업 수

변경 데이터 캡처 핸들러와 관련된 옵션만 보려면 커넥터 메시지 처리 속성 페이지를 참조하세요.

이름

설명

max.batch.size

유형: int

설명:
처리 위해 함께 배치 할 싱크 레코드의 최대 개수입니다.

다음 레코드가 포함된 배치 가정해 보겠습니다.

[ 1, 2, 3, 4, 5 ]

로 0 설정하다 하면 connector 전체 배치 에 대해 단일 대량 쓰기 (write) 수행합니다.

로 설정하다 1 하면 connector 배치 의 각 기록 에 대해 한 번의 대량 쓰기 (write) 수행하여 다음 예시 와 같이 총 5개의 대량 쓰기를 수행합니다.

[1], [2], [3], [4], [5]

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

bulk.write.ordered

유형: 부울

설명:
connector 레코드 배치 를 순서가 지정된 대량 쓰기 작업으로 쓰는지, 아니면 순서가 지정되지 않은 대량 쓰기 (write) 작업으로 쓰는지 여부를 나타냅니다.true 기본값 인 로 설정하다 하면 connector 레코드 배치 를 순서가 지정된 대량 쓰기 (write) 작업으로 씁니다.

대량 쓰기 (write) 작업에 대해 자세히 학습 대량 쓰기 작업을 참조하세요.

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

rate.limiting.every.n

유형: int

설명:
속도 제한 시간 초과를 트리거하다 하기 위해 싱크 connector 처리하는 레코드 배치 수입니다. 값은 0 속도 제한이 없음을 의미합니다.

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

rate.limiting.timeout

유형: int

설명:
속도 제한 임계값에 도달한 후 싱크 connector 처리 다시 시작하기 전에 대기해야 하는 시간(밀리초)입니다.

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

Tasks.max

유형: int

설명:
이 connector 에 대해 만들 수 있는 최대 작업 수입니다. connector 사용자가 지정한 병렬 처리 수준을 처리하다 할 수 없는 경우, 지정된 최대 작업보다 적게 생성할 수 있습니다.

중요: 보다 큰 값을 1 지정하면 connector 작업의 병렬 처리 활성화합니다. 주제 에 여러 개의 파티션 로그가 있어 connector 주제 를 병렬로 읽을 수 있는 경우 작업이 메시지를 순서대로 프로세스 않을 수 있습니다.

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

커넥터 오류 처리

다음 구성 설정을 사용하여 MongoDB Kafka connector가 오류를 처리하는 방법을 지정하고 데드 레터 큐를 구성합니다.

오류 처리와 관련된 옵션만 보려면 커넥터 오류 처리 속성 페이지를 참조하세요.

이름	설명
mongo.errors.tolerance	유형: 문자열 설명: connector 오류가 발생하는 경우 메시지를 계속 처리 할지 여부입니다. connector `errors.tolerance` Kafka 클러스터 설정을 재정의할 수 있도록 허용합니다. 로 설정하다 `none` 하면 connector 는 오류를 보고하고 나머지 메시지의 추가 처리 차단합니다. 로 설정하다 `all` 하면 connector 는 문제가 있는 메시지를 무시합니다. 로 설정하다 `data` 하면 connector 데이터 오류만 허용하고 다른 모든 오류에서는 실패합니다. 오류 처리 전략에 대해 자세히 학습 오류 처리 페이지를 참조하세요. 이 속성 연결 프레임워크의 errors.tolerance 속성 재정의합니다. 기본값:`errors.tolerance` 설정에서 값을 상속합니다. 허용되는 값: `"none"` 또는 `"all"`
mongo.errors.log.enable	유형: 부울 설명: connector 실패한 작업을 포함한 오류의 세부 정보를 로그 파일 에 쓰기 (write) 할지 여부입니다. connector 는 `errors.tolerance` 또는 설정을 사용하여 오류를 '허용됨' 또는 '허용되지 않음'으로 `mongo.errors.tolerance` 분류합니다. 로 설정하다 `true` 하면 connector 는 '허용되는' 오류와 '허용되지 않는' 오류를 모두 기록합니다. 로 설정하다 `false` 하면 connector 는 '허용되지 않음' 오류를 기록합니다. 이 속성 오류를 재정의합니다.로그. 연결 프레임워크의 `false` 활성화 속성 . 기본값: 허용되는 값: `true` 또는 `false`
errors.log.include.message	유형: 부울 설명: connector 오류를 기록할 때 잘못된 메시지를 포함할지 여부입니다. 잘못된 메시지에는 기록 키, 값, 헤더 등의 데이터가 포함됩니다. 기본값: `false` 허용되는 값: `true` 또는 `false`
errors.deadletterqueue.topic.name	유형: 문자열 설명: 데드 레터 큐 로 사용할 주제 이름입니다. 이 항목이 비어 있으면 connector 데드 레터 큐 에 잘못된 메시지를 보내지 않습니다. 데드 레터 큐 에 대해 자세히 학습 데드 레터 대기열 구성 예제를 참조하세요. 기본값: `""` 허용되는 값: 유효한 Kafka 주제 이름
errors.deadletterqueue.context.headers.enable	유형: 부울 설명: connector 데드 레터 큐 에 메시지를 쓸 때 컨텍스트 헤더를 포함할지 여부입니다. 데드 레터 큐 에 대해 자세히 학습 데드 레터 대기열 구성 예제를 참조하세요. connector 가 컨텍스트 헤더를 통해 정의하고 보고하는 예외에 대해 학습 대량 쓰기 예외를 참조하세요. 기본값: `false` 허용되는 값: `true` 또는 `false`
errors.deadletterqueue.topic.replication.factor	유형: 정수 설명: 데드 레터 큐 주제 복제할 노드 수입니다. 단일 노드 Kafka 클러스터 실행 경우 이를 로 설정하다 해야 `1` 합니다. 데드 레터 큐 에 대해 자세히 학습 데드 레터 대기열 구성 예제를 참조하세요. 기본값: `3` 허용되는 값: 유효한 노드 수

포스트 프로세서

다음 구성 설정을 사용하여 MongoDB Kafka connector가 Kafka 데이터를 MongoDB에 삽입하기 전에 변환하는 방법을 지정합니다.

포스트프로세서와 관련된 옵션만 보려면 싱크 connector 포스트프로세서 속성 페이지를 참조하세요.

이름

설명

post.processor.chain

유형: list

설명:
connector 데이터를 MongoDB 에 저장하기 전에 프로세스 위해 적용 해야 하는 포스트 프로세서 클래스 목록입니다.

포스트 프로세서에 대해 자세히 학습
사용 예제를 보려면
싱크 커넥터 포스트 프로세서를 참조하세요.

기본값:

com.mongodb.kafka.connect.sink.processor.DocumentIdAdder

허용되는 값: 쉼표로 구분된 정규화된 Java 클래스 이름 목록

field.renamer.mapping

유형: 문자열

설명:
키 및 값 필드에 대한 필드 이름 매핑 목록입니다. 다음 형식의 인라인 JSON 배열 에서 매핑을 정의합니다.

[ { "oldName":"key.fieldA", "newName":"field1" }, { "oldName":"value.xyz", "newName":"abc" } ]

기본값: []
허용되는 값: 유효한 JSON 배열

field.renamer.regexp

유형: 문자열

설명:
정규 표현식을 사용하는 키 및 값 필드에 대한 필드 이름 매핑 목록입니다. 다음 형식의 인라인 JSON 배열 에서 매핑을 정의합니다.

[ {"regexp":"^key\\\\..*my.*$", "pattern":"my", "replace":""}, {"regexp":"^value\\\\..*$", "pattern":"\\\\.", "replace":"_"} ]

기본값: []
허용되는 값: 유효한 JSON 배열

필드.value.transformer

유형:
문자열 설명:FieldValueTransformer 구현 의 정규화된 클래스 이름입니다. 구성되면 connector MongoDB 에 쓰기 전에 지정된 변환기를 에 나열된 필드에 field.value.transformer.fields 적용합니다. 클래스는 를 구현 해야 com.mongodb.kafka.connect.sink.processor.field.transform.FieldValueTransformer 하며 인수가 없는 공개 생성자가 있어야 합니다.

기본값: ""
허용되는 값: 정규화된 Java 클래스 이름

필드.value.transformer.fields

유형:
문자열 설명: connector 구성된 FieldValueTransformer 을 적용하는 쉼표로 구분된 필드 이름 목록입니다. 또한 connector 이름이 일치하는 하위 문서의 중첩 필드를 변환합니다.

기본값: ""
허용되는 값: 쉼표로 구분된 필드 이름 목록

key.projection.list

유형:
문자열 설명: connector 키 프로젝션 에 포함해야 하는 필드 이름의 목록입니다.

기본값: ""
허용되는 값: 쉼표로 구분된 필드 이름 목록

key.projection.type

유형: 문자열

설명:
connector 에서 사용해야 하는 키 프로젝션 유형입니다.

기본값: none
허용되는 none값:, BlockList 또는 AllowList (더 이상 사용되지 않음: blacklist, whitelist)

value.projection.list

유형:
문자열 설명: connector 값 프로젝션 에 포함해야 하는 필드 이름의 목록입니다.

기본값: ""
허용되는 값: 쉼표로 구분된 필드 이름 목록

value.projection.type

유형: 문자열

설명:
connector 에서 사용해야 하는 값 프로젝션 의 유형입니다.

기본값: none
허용되는 none값:, BlockList 또는 AllowList (더 이상 사용되지 않음: blacklist, whitelist)

writemodel.strategy

유형: 문자열

설명:
connector WriteModelStrategy 대량 쓰기에 사용해야 하는 를 지정하는 클래스입니다.

나만의 전략을 만드는 방법에 대해 자세히
학습 사용자 지정 쓰기 모델 전략을 참조하세요.

기본값:

com.mongodb.kafka.connect.sink.writemodel.strategy.DefaultWriteModelStrategy

허용되는 값: 정규화된 Java 클래스 이름

ID 전략

다음 구성 설정을 사용하여 MongoDB Kafka 싱크 커넥터가 MongoDB에 쓰는 각 문서의 _id 값을 결정하는 방법을 지정합니다.

문서의 _id 필드 결정과 관련된 옵션만 보려면 connector ID 전략 속성 페이지를 참조하세요.

이름

설명

document.id.strategy

유형: 문자열

설명:
connector 고유한 필드 생성하는 데 사용해야 하는 _id 클래스입니다.

기본값:

com.mongodb.kafka.connect.sink.processor.id.strategy.BsonOidStrategy

허용되는 값: 빈 string 또는 정규화된 Java 클래스 이름

document.id.strategy.overwrite.existing

유형: 부울

설명:
connector _id document.id.strategy 속성 에 정의된 전략을 적용할 때 필드 의 기존 값을 덮어쓸지 여부입니다.

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

document.id.strategy.uuid.format

유형: 문자열

설명:
connector 필드 의 UUID를 _id 문자열 형식으로 출력할지 BsonBinary 형식으로 출력할지 여부입니다.

기본값: string
허용되는 값: string 또는 binary

delete.on.null.values

유형: 부울

설명:
키 값이 MongoDB 의 문서 와 일치하고 값 필드 null인 경우 connector

문서를 삭제 할지 여부.FullKeyStrategy 이PartialKeyStrategy 설정은,, 와 같은 키 문서 에서 작동하는 ID 생성 전략을 지정할 때 ProvidedInKeyStrategy 적용됩니다.

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

쓰기 모델 전략

구성 속성을 설정하여 MongoDB Kafka 싱크 connector 가 MongoDB 에 데이터를 쓰는 방법을 지정할 수 있습니다. 다음 섹션에서는 이 동작을 사용자 지정하기 위해 설정할 수 있는 구성 속성에 대해 설명합니다.

WriteModel

writemodel.strategy 구성 속성을 설정하여 싱크 connector 가 싱크 기록을 수신할 때 데이터를 쓰는 방법을 지정합니다.

이 페이지의 전략 섹션에 설명된 쓰기 모델 전략의 정규화된 클래스 이름 중 하나로 writemodel.strategy 값을 설정할 수 있습니다. 다음 구성을 설정하여 전략을 지정할 수 있습니다.

writemodel.strategy=<a write model strategy>

쓰기 모델 삭제

싱크 connector 가 툼스톤 이벤트를 수신할 때 데이터를 쓰는 방법을 지정하려면 delete.writemodel.strategy 구성 속성을 설정합니다. 툼스톤 이벤트는 키가 있지만 값이 없는 레코드로, 삭제된 레코드를 나타냅니다.

이 페이지의 전략 섹션에 설명된 쓰기 모델 전략의 정규화된 클래스 이름 중 하나로 delete.writemodel.strategy 값을 설정할 수 있습니다. 다음 구성을 설정하여 전략을 지정할 수 있습니다.

delete.writemodel.strategy=<a write model strategy>

쓰기 모델 전략과 관련된 옵션만 보려면 싱크 connector 쓰기 모델 전략 페이지를 참조하세요.

이름

설명

DefaultWriteModelStrategy

설명:
이 전략은 ReplaceOneDefaultStrategy InsertOneDefaultStrategy timeseries.timefield

기본값 으로 을 사용하고, 옵션을 설정하다 경우 를 사용합니다. 이는 writemodel.strategy 구성 속성 의 기본값 입니다.

InsertOneDefaultStrategy

설명:
각 싱크 기록 MongoDB 에 문서 로 삽입합니다.
이 전략을 지정하려면 구성 속성 다음 클래스 이름으로 설정하다 .

com.mongodb.kafka.connect.sink.writemodel.strategy.InsertOneDefaultStrategy

ReplaceOneDefaultStrategy

설명:
싱크 기록 와 일치하는 MongoDB 의 문서 최대 하나를 필드 _id 로 바꿉니다. 일치하는 문서가 없는 경우 connector 싱크 기록 새 문서 로 삽입합니다.
이 전략을 지정하려면 구성 속성 다음 클래스 이름으로 설정하다 .

com.mongodb.kafka.connect.sink.writemodel.strategy.ReplaceOneDefaultStrategy

하나의 비즈니스 키 교체 전략

설명:
싱크 기록 과 일치하는 문서 최대 한 개만 지정된 비즈니스 키로 바꿉니다. 일치하는 문서가 없는 경우 connector 싱크 기록 새 문서 로 삽입합니다.
이 전략을 지정하려면 구성 속성 다음 클래스 이름으로 설정하다 .

com.mongodb.kafka.connect.sink.writemodel.strategy.ReplaceOneBusinessKeyStrategy

이 전략을 사용하는 방법을 보여주는 예를 보려면 쓰기 모델 전략 가이드를 참조하세요.

DeleteOneDefaultStrategy

설명:문서 null 값 구조가 포함된 경우에만 필드 에서
싱크 커넥터의 키 구조와 일치하는 문서 하나만 삭제합니다._id

이는 delete.writemodel.strategy 구성 속성 의 기본값 입니다.

이 전략은 writemodel.strategy 를 설정하다 때 속성 의 기본값 으로 delete.on.null.values=true 설정하다 됩니다. 이
전략을 지정하려면 구성 속성 다음 클래스 이름으로 설정하다 .

com.mongodb.kafka.connect.sink.writemodel.strategy.DeleteOneDefaultStrategy

하나의 비즈니스 키 삭제 전략

설명:
비즈니스 키별로 싱크 기록 과 일치하는 MongoDB 문서 최대 한 개 삭제합니다. 이 전략에는 키 valueDoc 생성을 위해 이(가) 필요합니다.PartialKeyStrategy 키 생성에 을 활용하려면 를 DeleteOneTombstoneBusinessKeyStrategy 사용합니다. 이

전략을 지정하려면 구성 속성 다음 클래스 이름으로 설정하다 .

com.mongodb.kafka.connect.sink.writemodel.strategy.DeleteOneBusinessKeyStrategy

이 전략을 사용하는 방법을 보여주는 예를 보려면 쓰기 모델 전략 가이드를 참조하세요.

DeleteOneTombstoneBusinessKeyStrategy

설명:
비즈니스 키별로 싱크 기록 과 일치하는 MongoDB 문서 최대 한 개 삭제합니다. 이 전략은 을 활용하여 PartialKeyStrategy 삭제에 사용되는 키를 생성합니다. 이

전략을 지정하려면 구성 속성 다음 클래스 이름으로 설정하다 .

com.mongodb.kafka.connect.sink.writemodel.strategy.DeleteOneTombstoneBusinessKeyStrategy

UpdateOneDefaultStrategy

설명:
필드 별로 싱크 기록 와 일치하는 MongoDB 의 문서 최대 한 개 _id 업데이트합니다. 일치하는 문서가 없는 경우 connector 싱크 기록 새 문서 로 삽입합니다.
이 전략을 지정하려면 구성 속성 다음 클래스 이름으로 설정하다 .

com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneDefaultStrategy

하나의 타임스탬프 업데이트 전략

설명:문서에(타임스탬프
_insertedTS 삽입) 및(수정된 타임스탬프) 필드를 추가합니다._modifiedTS
이 전략을 지정하려면 구성 속성 다음 클래스 이름으로 설정하다 .

com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneTimestampsStrategy

이 전략을 사용하는 방법을 보여주는 예를 보려면 쓰기 모델 전략 가이드를 참조하세요.

UpdateOneBusinessKeyTimestampStrategy

설명:비즈니스 키와 일치하는 문서에(삽입된
_insertedTS 타임스탬프) 및(수정된 타임스탬프) 필드를 추가합니다._modifiedTS
이 전략을 지정하려면 구성 속성 다음 클래스 이름으로 설정하다 .

com.mongodb.kafka.connect.sink.writemodel.strategy.UpdateOneBusinessKeyTimestampStrategy

주제 재정의

다음 MongoDB Kafka sink connector 구성 설정을 사용하여 특정 주제에 대한 전역 또는 기본 속성 설정을 재정의할 수 있습니다.

주제 설정 재정의와 관련된 옵션만 보려면 주제 재정의 속성 페이지를 참조하세요.

이름	설명
topic.override.<topicName>.<propertyName>	유형: 문자열 설명: 해당 전역 또는 `topic.override.foo.collection=bar` 기본값 속성 설정을 재정의하려면 `foo` 주제 와 속성 이름을 `bar` 지정합니다. 예시 를 들어 설정은 주제 의 데이터를 컬렉션 에 저장 하도록 싱크 connector 에 지시합니다. `<propertyName>` `connection.uri` 및 를 제외하고 세그먼트에서 주제별로 유효한 구성 설정을 지정할 수 `topics` 있습니다. 기본값: `""` 허용되는 값: 재정의된 속성 과 관련하여 허용되는 값

이름

설명

topic.override.<topicName>.<propertyName>

유형:
문자열 설명: 해당 전역

또는 topic.override.foo.collection=bar
기본값 속성 설정을 재정의하려면 foo 주제 와 속성 이름을 bar
지정합니다.

예시 를 들어 설정은 주제 의 데이터를 컬렉션 에 저장 하도록 싱크 connector 에 지시합니다.
<propertyName>
connection.uri 및 를 제외하고 세그먼트에서 주제별로 유효한 구성 설정을 지정할 수 topics 있습니다.

기본값: ""
허용되는 값: 재정의된 속성 과 관련하여 허용되는 값

데이터 캡처 변경

다음 구성 설정을 사용하여 MongoDB Kafka 싱크 connector 가 변경 데이터 캡처(CDC) 이벤트를 처리하는 데 사용하는 클래스를 지정합니다.

내장 ChangeStreamHandler 및 Debezium 및 Qlik Replicate 이벤트 생성자를 위한 핸들러를 사용하는 예제는 변경 데이터 캡처 핸들러 가이드 를 참조하세요.

변경 데이터 캡처 핸들러와 관련된 옵션만 보려면 변경 데이터 캡처 속성 페이지를 참조하세요.

이름	설명
change.data.capture.handler	유형: 문자열 설명: 변경 사항을 이벤트 스트림으로 변환하는 데 사용할 CDC 핸들러의 클래스 이름입니다. CDC 핸들러 목록은 사용 가능한 CDC 핸들러를 참조하세요. 기본값: `""` 허용되는 값: 빈 문자열 또는 정규화된 Java 클래스 이름

시계열

다음 구성 설정을 사용하여 MongoDB Kafka connector가 데이터를 MongoDB time-series collection에 싱크하는 방법을 지정합니다.

time series 컬렉션과 관련된 옵션만 보려면 Kafka time-series 속성 페이지를 참조하세요.

이름

설명

timeseries.timefield

유형: 문자열

설명:
time series 컬렉션 의 새 문서 와 연결하려는 시간 정보가 포함된 소스 데이터의 최상위 필드 이름입니다.

기본값: ""
허용되는 값: 빈 문자열 또는 BSON DateTime 값이 포함된 필드 이름

timeseries.timefield.auto.convert.date.format

유형: 문자열

설명:
connector 설정으로 지정된 필드 에 포함된 소스 데이터를 변환하는 데 사용해야 하는 날짜 timeseries.timefield 형식

패턴 . connector 날짜 형식 패턴 Java DateTimeFormatter.ofPattern(패턴, 국가 및 언어 설정) 메서드에 전달하여 시간 필드 에서 날짜 및 시간 변환을

수행합니다. 소스 데이터의 날짜 값에 날짜 정보만 포함된 경우 connector 시간 정보를 지정된 날짜의 시작으로 설정합니다. 날짜 값에 표준 시간대 오프셋이 포함되어 있지 않으면 connector 는 오프셋을 UTC로 설정합니다.

기본값:

yyyy-MM-dd[['T'][ ]][HH:mm:ss[[.][SSSSSS][SSS]][ ]VV[ ]'['VV']'][HH:mm:ss[[.][SSSSSS][SSS]][ ]X][HH:mm:ss[[.][SSSSSS][SSS]]]

허용되는 값: 유효한 DateTimeFormatter 형식

timeseries.timefield.auto.convert

유형: 부울

설명:
필드 의 데이터를 BSON Date 형식으로 변환할지 여부입니다.

로 설정하다 true 하면 connector 에포크 후 밀리초를 사용하고 값이 숫자인 경우 분수 부분을 삭제합니다. 값이 문자열인 경우 connector 다음 구성의 설정을 사용하여 날짜를 구문 분석합니다.

timeseries.timefield.auto.convert.date.format

connector 값을 변환하지 못하면 원래 값을 time series 컬렉션 으로 보냅니다.

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

timeseries.timefield.auto.convert.locale. Language.tag

유형: string

설명:
날짜 형식 패턴에 사용할 DateTimeFormatter 국가 및 언어 설정 언어 태그(예: "en-US").

국가 및 언어 설정에 대한 자세한 내용은 Locale의 Java SE 문서를 참조하세요.

기본값: ROOT
허용 값: 유효한 Locale 언어 태그 형식

timeseries.metafield

유형: 문자열 설명: 관련

Time Series 문서 그룹 설명하기 위해 소스 데이터에서 읽을 최상위 필드 입니다.

중요: 이 필드 _id 필드 또는 timeseries.timefield 설정에서 지정한 필드 아니어야 합니다.

""
기본값:허용되는 값: 를 제외한 BSON types를 포함하는 빈 문자열 또는 필드 의 BsonArray 이름입니다.

timeseries.expire.after.seconds

유형: int

설명:
time series 컬렉션 데이터를 자동으로 제거하기 전에 MongoDB 대기해야 하는 시간(초)입니다. 설정 값이 보다 작으면 connector 시간 만료를 비활성화합니다.1

자세한 학습 은 MongoDB 매뉴얼의 Time Series 컬렉션에 대한 자동 제거 설정을 참조하세요.

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

timeseries. granularity

유형: 문자열

설명:
소스 데이터의 후속 측정 사이의 예상 간격입니다.

자세한 학습 은 MongoDB 매뉴얼의 Time Series 데이터에 대한 세분성 설정을 참조하세요.

선택적
기본값: ""
허용되는 값:,,, """seconds""minutes""hours"

기존 컬렉션을 Time Series 컬렉션으로 변환하는 방법에 대한 예 는 기존 컬렉션을 Time Series 컬렉션으로 마이그레이션하는 방법에 대한 튜토리얼을 참조하세요.

돌아가기

시계열

Fundamentals