싱크 커넥터 포스트프로세서 속성

post.processor.chain

형식: 목록

설명:
커넥터가 MongoDB에 데이터를 저장하기 전에 데이터를 처리하기 위해 적용해야 하는 게시 프로세서 클래스 목록입니다.

게시 프로세서에 대해 자세히 알아보고 사용 예시를 확인하려면
다음을 참조하세요.
Sink Connector 게시 프로세서.

기본값:

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

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

field.renamer.mapping

유형: string

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

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

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

field.renamer.regexp

Type: string

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

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

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

필드.value.transformer

유형: string

설명:
FieldValueTransformer 구현의 정규화된 클래스 이름입니다. 구성된 경우 커넥터는 MongoDB에 기록하기 전에 field.value.transformer.fields 에 나열된 필드에 지정된 트랜스포머를 적용합니다. 클래스는 com.mongodb.kafka.connect.sink.processor.field.transform.FieldValueTransformer 를 구현해야 하며 공개 노아그 생성자가 있어야 합니다.

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

field.value.transformer.fields

유형: string

설명:
커넥터가 구성된 FieldValueTransformer을 적용하는 필드 이름의 심표로 구분된 목록입니다. 커넥터는 일치하는 이름의 하위 문서에서 중청 필드도 변환합니다.

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

key.projection.list

유형: string

설명:
커넥터가 키 프로젝션에 포함해야 할 필드 이름 목록입니다.

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

key.projection.type

유형: string

설명:
커넥터가 사용해야 하는 키 프로젝션 유형입니다.

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

value.projection.list

유형: string

설명:
커넥터가 값 프로젝션에 포함해야 할 필드 이름 목록입니다.

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

value.projection.type

유형: string

설명:
커넥터가 사용해야 하는 값 프로젝션의 유형입니다.

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

writemodel.strategy

유형: 문자열

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

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

기본값:

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

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