MongoDB 네임스페이스 매핑 구성 속성
이 페이지의 내용
개요
다음 구성 설정을 사용하여 MongoDB Kafka connector가 데이터를 쓰는 MongoDB database 및 collection을 지정합니다. 기본 DefaultNamespaceMapper 를 사용하거나 사용자 지정 클래스를 지정할 수 있습니다.
카테고리별로 정리된 싱크 connector 구성 설정 목록은 싱크 Connector 구성 속성가이드 를 참조하세요.
설정
이름 | 설명 | |
|---|---|---|
namespace.mapper | Type: string Description: The fully-qualified class name of the class that specifies which
database or collection in which to sink the data. The default
DefaultNamespaceMapper uses values specified in the
database and collection properties.The connector includes an alternative class for specifying the database and collection called FieldPathNamespaceMapper. Seefor more information. Default: Accepted Values: A fully qualified Java class name of a class that implements the NamespaceMapper interface. | |
database | Required Type: string Description: The name of the MongoDB database to which the sink connector writes. Accepted Values: A MongoDB database name | |
컬렉션 | Type: string Description: The name of the MongoDB collection to which the sink connector
writes. If your sink connector follows multiple topics, this
is the default collection for any writes that are not otherwise
specified. Default: The topic name. Accepted Values: A MongoDB collection name |
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 | Type: string Description: The name of the key document field that specifies the name of the
database in which to write. |
namespace.mapper.key.collection.field | Type: string Description: The name of the key document field that specifies the name of the
collection in which to write. |
namespace.mapper.value.database.field | Type: string Description: The name of the value document field that specifies the name of the
database in which to write. |
namespace.mapper.value.collection.field | Type: string Description: The name of the value document field that specifies the name of the
collection in which to write. |
namespace.mapper.error.if.invalid | Type: boolean Description: Whether to throw an exception when either the document is missing the
mapped field or it has an invalid BSON type. When set to true, the connector does not process documents
missing the mapped field or that contain an invalid BSON type.
The connector may halt or skip processing depending on the related
error-handling configuration settings.When set to false, if a document is missing the mapped field or
if it has an invalid BSON type, the connector defaults to
writing to the specified database and collection settings.Default: falseAccepted Values: true or false |