/ /

싱크 커넥터 쓰기 모델 전략

개요

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

WriteModel

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

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

writemodel.strategy=<a write model strategy>

쓰기 모델 삭제

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

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

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

카테고리별로 정리된 싱크 connector 구성 설정 목록은 싱크 Connector 구성 속성가이드 를 참조하세요.

Strategies

이름

설명

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

돌아가기

ID 전략

주제 재정의