/ /

MongoDB 네임스페이스 매핑 구성 속성

개요

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

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

설정

이름

설명

namespace.mapper

유형: string

설명:
데이터를 싱크할 데이터베이스 또는 컬렉션을 지정하는 클래스의 완전히 경로가 지정된 클래스 이름입니다. 기본 DefaultNamespaceMapper 은 database 속성과 collection 속성에 지정된 값을 사용합니다.

커넥터에는 데이터베이스와 컬렉션을 지정하는 대체 클래스인 이 포함되어
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 주제