/ /

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

필수 사항

유형: string

설명:
싱크 커넥터가 쓰기 (write)하는 MongoDB 데이터베이스의 이름입니다.

허용되는 값: MongoDB 데이터베이스 이름

컬렉션

유형: string

설명:
싱크 커넥터가 쓰는 MongoDB 컬렉션의 이름입니다. 싱크 커넥터가 여러 개의 주제를 팔로우하는 경우, 이는 별도 지정되지 않은 모든 쓰기의 기본 컬렉션입니다.

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

허용되는 값: 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	유형: string 설명: 쓰기 (write)할 데이터베이스의 이름을 지정하는 키 문서 필드의 이름입니다.
namespace.mapper.key.collection.field	유형: string 설명: 쓰기 (write)할 컬렉션의 이름을 지정하는 키 문서 필드의 이름입니다.
namespace.mapper.value.database.field	유형: string 설명: 쓰기할 데이터베이스의 이름을 지정하는 값 문서 필드의 이름입니다.
namespace.mapper.value.collection.field	유형: string 설명: 쓰기할 컬렉션 이름을 지정하는 값 문서 필드의 이름입니다.
namespace.mapper.error.if.invalid	유형: 불리언 설명: 문서에 매핑된 필드가 없거나 유효하지 않은 BSON 유형인 경우 예외를 발생시킬 여부입니다. `true`으로 설정하면 커넥터는 매핑된 필드가 없거나 유효하지 않은 BSON 유형을 포함하는 문서를 처리하지 않습니다. 커넥터는 관련 오류 처리 구성 설정에 따라 처리를 중단하거나 건너랋니다. `false`로 설정하면 문서에 매핑된 필드가 없거나 유효하지 않은 BSON 유형인 경우 커넥터는 지정된 `database` 및 `collection` 설정에 기본적으로 기록합니다. 기본값: `false` 허용 값: `true` 또는 `false`

돌아가기

MongoDB 연결

Kafka 주제