/ /

싱크 커넥터

구성 속성

Docs Home

도구

Kafka 커넥터

싱크 커넥터

구성 속성

모든 싱크 커넥터 구성 속성

개요

이 페이지에서는 MongoDB Kafka connector에 사용 가능한 모든 속성을 볼 수 있습니다. 이 페이지는 다른 싱크 connector 구성 속성 속성 페이지의 내용을 복제합니다.

모든 connector 구성 속성 페이지의 목록을 보려면 connector 구성 속성 페이지를 참조하세요.

MongoDB 연결

다음 구성 설정을 사용하여 MongoDB Kafka 싱크 connector 가 MongoDB cluster 와 연결하고 통신하는 방법을 지정합니다.

MongoDB 연결 구성과 관련된 옵션만 보려면 MongoDB 연결 구성 속성 페이지를 참조하세요.

이름	설명
connection.uri	필수 사항 Type: string Description: The MongoDB connection URI string to connect to your MongoDB instance or cluster. For more information, see the Connect to MongoDB guide 중요한: `connection.uri` 설정에서 인증 자격 증명 노출되지 않도록 하려면 ConfigProvider 를 사용하고 적절한 구성 매개 변수를 설정하다. 기본값: `mongodb://localhost:27017` 허용되는 값: MongoDB 연결 URI string
server.api.version	Type: string Description: The Stable API version you want to use with your MongoDB server. For more information on the Stable API and versions of the server that support it, see the Stable API MongoDB server manual guide. Default: `""` Accepted Values: An empty string or a valid Stable API version.
server.api.deprecationErrors	Type: boolean Description: When set to `true`, if the connector calls a command on your MongoDB instance that's deprecated in the declared Stable API version, it raises an exception. You can set the API version with the `server.api.version` configuration option. For more information on the Stable API, see the MongoDB manual entry on the Stable API. Default: `false` Accepted Values: `true` or `false`
server.api.strict	Type: boolean Description: When set to `true`, if the connector calls a command on your MongoDB instance that's not covered in the declared Stable API version, it raises an exception. You can set the API version with the `server.api.version` configuration option. For more information on the Stable API, see the MongoDB manual entry on the Stable API. Default: `false` Accepted Values: `true` or `false`

MongoDB 네임스페이스

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

커넥터가 데이터를 쓰는 위치 지정과 관련된 옵션만 보려면 MongoDB 네임스페이스 매핑 구성 속성 페이지를 참조하세요.

이름

설명

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 sink connector가 데이터를 감시해야 하는 Kafka 주제를 지정합니다.

Kafka 주제 지정과 관련된 옵션만 보려면 싱크 커넥터의 Kafka 주제 속성 페이지를 참조하세요.

이름

설명

주제

필수 사항

유형: 목록

설명:
싱크 커넥터가 모니터링하는 Kafka 주제 목록입니다.

topics 또는 topics.regex 설정 중 하나를 정의할 수 있지만 둘 다 정의할 수는 없습니다.

허용되는 값: 쉼표로 구분된 유효한 Kafka 주제 목록

topic.regex

필수 사항

유형: string

설명:
싱크 커넥터가 모니터링하는 Kafka 주제와 일치하는 정규 표현식입니다.

예를 예시, 다음 정규식은 "activity.landing.Clicks" 와 같은 주제 이름과 일치합니다. 및 '활동. 지원.클릭'. 주제 이름 'Activity.landing.views'와(과) 일치하지 않습니다. 및 'activity.Clicks'.

topics.regex=activity\\.\\w+\\.clicks$

topics 또는 topics.regex 설정 중 하나를 정의할 수 있지만 둘 다 정의할 수는 없습니다.

허용되는 값: java.util.regex.Pattern 을(를) 사용하는 유효한 정규 표현식 패턴입니다.

커넥터 메시지 처리

이 페이지의 설정을 사용하여 다음을 포함하여 MongoDB Kafka connector의 메시지 처리 동작을 구성합니다.

메시지 배치 크기
속도 제한
병렬 작업 수

변경 데이터 캡처 핸들러와 관련된 옵션만 보려면 커넥터 메시지 처리 속성 페이지를 참조하세요.

이름

설명

max.batch.size

유형: int

설명:
처리를 위해 배치로 부르는 싱크 기록의 최대 수입니다.

다음 기록이 포함된 배치를 고려해 보겠습니다.

[ 1, 2, 3, 4, 5 ]

0으로 설정되면 커넥터는 전체 배치에 대해 단일 불크 쓰기 (write)를 수행합니다.

1으로 설정되면 커넥터는 배치의 각 기록에 대해 하나의 불크 쓰기 (write)를 수행하며, 다음 예시에 표시된 것처럼 총 5개의 불크 쓰기 (write)를 수행합니다.

[1], [2], [3], [4], [5]

기본값: 0
허용 값: 정수

bulk.write.ordered

유형: 불리언

설명:
커넥터가 배치 기록을 정렬 또는 비정렬 대량 쓰기 (write) 작업으로 쓰는지 여부입니다. true으로 설정된 경우(기본값), 커넥터가 배치 기록을 정렬 대량 쓰기 (write) 작업으로 쓰기 (write)합니다.

대량 쓰기 (write) 작업에 대해 학습하려면 대량 쓰기 (write) 작업을 참조하세요.

기본값: true
허용 값: true 또는 false

rate.limiting.every.n

유형: int

설명:
속도 제한 시간 초과를 trigger하기 위해 싱크 커넥터가 처리하는 기록 배치 수. 0 값은 속도 제한이 없음을 의미합니다.

기본값: 0
허용되는 값: 정수

rate.limiting.timeout

유형: int

설명:
성능 제한 임계값에 도달한 후 싱크 커넥터가 처리를 재개하기 전에 대기할 시간(밀리초)입니다.

기본값: 0
허용 값: 정수

Tasks.max

유형: int

설명:
이 커넥터에 대해 만들 최대 작업 수. 커넥터는 지정한 최대 작업 수보다 적은 수의 작업을 만들 수 있습니다. 이는 지정한 병렬성 수준을 처리할 수 없는 경우에 해당합니다.

중요: 1보다 큰 값을 지정하면 커넥터는 작업의 병렬 처리를 활성화합니다. 주제에 여러 개의 분할 로그가 있으면 커넥터가 주제에서 병렬적으로 읽을 수 있으므로 작업이 메시지를 순서와 상관없이 처리할 수 있습니다.

기본값: 1
허용되는 값: 정수

커넥터 오류 처리

다음 구성 설정을 사용하여 MongoDB Kafka connector가 오류를 처리하는 방법을 지정하고 데드 레터 큐를 구성합니다.

오류 처리와 관련된 옵션만 보려면 커넥터 오류 처리 속성 페이지를 참조하세요.

이름	설명
mongo.errors.tolerance	유형: string 설명: 커넥터에 오류가 발생한 경우 메시지 처리를 계속할지 여부입니다. 커넥터가 `errors.tolerance` Kafka 클러스터 설정을 재정의할 수 있도록 허용합니다. `none`으로 설정하면 커넥터가 오류를 보고하고 나머지 메시지의 추가 처리를 차단합니다. `all`로 설정하면 커넥터가 문제가 있는 메시지를 무시합니다. `data`으로 설정하면 커넥터가 데이터 오류만 허용하고 나머지 모든 오류에서는 실패합니다. 오류 처리 전략에 대해 자세히 알아보려면 오류 처리 페이지를 참조하세요. 이 속성은 errors.tolerance Connect Framework의 속성을 재정의합니다. 기본값: `errors.tolerance` 설정의 값을 상속합니다. 허용 값: `"none"` 또는 `"all"`
mongo.errors.log.enable	유형: 불리언 설명: 커넥터가 실패한 작업을 포함하여 오류 세부 정보를 로그 파일에 쓰어야 하는지 여부. 커넥터는 `errors.tolerance` 또는 `mongo.errors.tolerance` 설정을 사용하여 오류를 "허용되지 않음" 또는 "허용됨"으로 분류합니다. `true`로 설정하면 커넥터는 "허용됨" 및 "허용되지 않음" 오류 모두를 로그합니다. `false`으로 설정하면 커넥터는 "허용되지 않음" 오류만 로그합니다. 이 속성은 Connect Framework의 errors.로그.enable Connect 프레임워크의 속성입니다. 기본값: `false` 허용되는 값: `true` 또는 `false`
errors.log.include.message	유형: 불리언 설명: 에러 로그인시 커넥터에 유효하지 않은 메시지를 포함해야 하는지 여부를 지정합니다. 유효하지 않은 메시지에는 기록 키, 값 및 헤더 등의 데이터가 포함됩니다. 기본값: `false` 허용 값: `true` 또는 `false`
errors.deadletterqueue.topic.name	유형: string 설명: 데드 레터 큐로 사용할 주제의 이름입니다. 빈 칸이면 커넥터는 유효하지 않은 메시지를 데드 레터 큐에 보내지 않습니다. 데드 레터 큐에 대해 자세히 학습하려면 데드 레터 큐 구성 예시를 참조하세요. 기본값: `""` 허용되는 값: 유효한 Kafka 주제 이름
errors.deadletterqueue.context.headers.enable	유형: 불리언 설명: 커넥터가 데드 레터 큐에 메시지를 쓰는 경우 컨텍스트 헤더를 포함해야 합니까? 데드 레터 큐에 대해 자세히 학습하려면 데드 레터 큐 구성 예시를 참조하세요. connector가 정의하고 컨텍스트 헤더를 통해 보고하는 예외에 대해 알아보려면 대량 쓰기 예외를 참조하세요. 기본값: `false` 허용 값: `true` 또는 `false`
errors.deadletterqueue.topic.replication.factor	유형: 정수 설명: 데드 레터 큐 주제를 복제할 노드 수입니다. 단일 노드 Kafka 클러스터를 실행하는 경우 이 값을 `1`으로 설정해야 합니다. 데드 레터 큐에 대해 자세히 학습하려면 데드 레터 큐 구성 예시를 참조하세요. 기본값: `3` 허용 값: 유효한 노드 수

포스트 프로세서

다음 구성 설정을 사용하여 MongoDB Kafka connector가 Kafka 데이터를 MongoDB에 삽입하기 전에 변환하는 방법을 지정합니다.

포스트프로세서와 관련된 옵션만 보려면 싱크 connector 포스트프로세서 속성 페이지를 참조하세요.

이름

설명

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 배열

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

Type: string

Description:
The class that specifies the WriteModelStrategy the connector should use for Bulk Writes.

To learn more about how to create your own strategy, see
Custom Write Model Strategies.

Default:

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

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

ID 전략

다음 구성 설정을 사용하여 MongoDB Kafka 싱크 커넥터가 MongoDB에 쓰는 각 문서의 _id 값을 결정하는 방법을 지정합니다.

문서의 _id 필드 결정과 관련된 옵션만 보려면 connector ID 전략 속성 페이지를 참조하세요.

이름

설명

document.id.strategy

유형: string

설명:
커넥터가 고유한 _id 필드를 생성하는 데 사용해야 하는 클래스입니다.

기본값:

com.mongodb.kafka.connect.sink.processor.id.strategy.BsonOidStrategy

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

document.id.strategy.overwrite.existing

유형: 불리언

설명:
connector가 document.id.strategy 속성으로 정의된 전략을 적용할 때 _id 필드의 기존 값을 덮어썸야 하는지 여부.

기본값: false
허용되는 값: true 또는 false

document.id.strategy.uuid.format

유형: string

설명:
커넥터가 _id 필드에 UUID를 string 형식으로 출력할지 BsonBinary 형식으로 출력할지 여부.

기본값: string
허용 값: string 또는 binary

delete.on.null.values

유형: 불리언

설명:
키 값이 MongoDB의 문서와 일치하고 값 필드가 null인 경우 커넥터가 문서를 삭제할지 여부입니다.

이 설정은 FullKeyStrategy, PartialKeyStrategy, ProvidedInKeyStrategy 등 키 문서에서 작동하는 ID 생성 전략을 지정할 때 적용됩니다.

기본값: false
허용 값: true 또는 false

쓰기 모델 전략

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

WriteModel

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

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

writemodel.strategy=<a write model strategy>

쓰기 모델 삭제

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

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

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

쓰기 모델 전략과 관련된 옵션만 보려면 싱크 connector 쓰기 모델 전략 페이지를 참조하세요.

이름

설명

DefaultWriteModelStrategy

설명:
이 전략은 기본적으로 ReplaceOneDefaultStrategy 을 사용하고, timeseries.timefield 옵션을 설정하면 InsertOneDefaultStrategy 을 사용합니다.

이것은 writemodel.strategy 구성 속성의 기본값입니다.

InsertOneDefaultStrategy

설명:
각 싱크 기록을 문서로 MongoDB에 삽입합니다.
이 전략을 지정하려면 구성 속성을 다음 클래스 이름으로 설정합니다.

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

ReplaceOneDefaultStrategy

설명:
_id 필드로 싱크 기록과 일치하는 MongoDB의 문서 최대 하나를 바꾸는 방법입니다. 일치하는 문서가 없는 경우 Connector는 싱크 기록을 새 문서로 삽입합니다.
이 전략을 지정하려면 구성 속성을 다음 클래스 이름으로 설정합니다.

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

하나의 비즈니스 키 교체 전략

설명:
지정된 비즈니스 키로 sink record와 일치하는 문서 최대 하나를 바꿅니다. 일치하는 문서가 없는 경우 Connector는 싱크 기록을 새 문서로 삽입합니다.
이 전략을 지정하려면 구성 속성을 다음 클래스 이름으로 설정합니다.

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

이 전략을 사용하는 방법을 보여주는 예를 보려면 쓰기 모델 전략 가이드를 참조하세요.

DeleteOneDefaultStrategy

설명:
문서에 null 값 구조가 포함되어 있는 경우에만 _id 필드로 싱크 커넥터의 키 구조와 일치하는 문서를 최대 하나 삭제합니다.

이것이 delete.writemodel.strategy 구성 속성의 기본값입니다.

delete.on.null.values=true을 설정하면 이 전략이 writemodel.strategy 속성의 기본값으로 설정됩니다.
이 전략을 지정하려면 구성 속성을 다음 클래스 이름으로 설정합니다.

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

하나의 비즈니스 키 삭제 전략

설명:
비즈니스 키를 기준으로 싱크 기록과 일치하는 MongoDB 문서를 최대 1개 삭제합니다. 이 전략에는 키 생성을 위해 valueDoc 이(가) 필요합니다. 키 생성을 위해 PartialKeyStrategy 을(를) 활용하려면 DeleteOneTombstoneBusinessKeyStrategy를 사용합니다.

이 전략을 지정하려면 구성 속성을 다음 클래스 이름으로 설정합니다.

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

이 전략을 사용하는 방법을 보여주는 예를 보려면 쓰기 모델 전략 가이드를 참조하세요.

DeleteOneTombstoneBusinessKeyStrategy

설명:
비즈니스 키로 싱크 기록과 일치하는 최대 하나의 MongoDB 문서를 삭제합니다. 이 전략은 PartialKeyStrategy 을 활용하여 삭제에 사용될 키를 만듭니다.

이 전략을 지정하려면 구성 속성을 다음 클래스 이름으로 설정합니다.

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

UpdateOneDefaultStrategy

설명:
_id 필드로 싱크 기록과 일치하는 MongoDB의 문서 최대 하나를 업데이트합니다. 일치하는 문서가 없는 경우 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

주제 재정의

다음 MongoDB Kafka sink connector 구성 설정을 사용하여 특정 주제에 대한 전역 또는 기본 속성 설정을 재정의할 수 있습니다.

주제 설정 재정의와 관련된 옵션만 보려면 주제 재정의 속성 페이지를 참조하세요.

이름	설명
topic.override.<topicName>.<propertyName>	유형: string 설명: 해당 전역 또는 기본값 속성 설정을 재정의하려면 주제와 속성 이름을 지정합니다. 예를 들어 `topic.override.foo.collection=bar` 설정은 싱크 커넥터에게 `foo` 주제의 데이터를 `bar` 컬렉션에 저장하도록 지시합니다. `<propertyName>` `connection.uri` 및 `topics` 를 제외하고 주제별로 세그먼트에서 유효한 구성 설정을 지정할 수 있습니다. 기본값: `""` 허용 값: 재정의된 속성에 특정한 허용 값

이름

설명

topic.override.<topicName>.<propertyName>

유형: string

설명:
해당 전역 또는 기본값 속성 설정을 재정의하려면 주제와 속성 이름을 지정합니다.

예를 들어 topic.override.foo.collection=bar 설정은
싱크 커넥터에게 foo 주제의 데이터를 bar
컬렉션에 저장하도록 지시합니다.

<propertyName>
connection.uri 및 topics 를 제외하고 주제별로 세그먼트에서 유효한 구성 설정을 지정할 수 있습니다.

기본값: ""
허용 값: 재정의된 속성에 특정한 허용 값

데이터 캡처 변경

다음 구성 설정을 사용하여 MongoDB Kafka 싱크 connector 가 변경 데이터 캡처(CDC) 이벤트를 처리하는 데 사용하는 클래스를 지정합니다.

내장 ChangeStreamHandler 및 Debezium 및 Qlik Replicate 이벤트 생성자를 위한 핸들러를 사용하는 예제는 변경 데이터 캡처 핸들러 가이드 를 참조하세요.

변경 데이터 캡처 핸들러와 관련된 옵션만 보려면 변경 데이터 캡처 속성 페이지를 참조하세요.

이름	설명
change.data.capture.handler	유형: string 설명: 변경 사항을 이벤트 스트림으로 변환하는 데 사용할 CDC 핸들러의 클래스 이름입니다. CDC 핸들러 목록은 사용 가능한 CDC 핸들러 를 참조하세요. 기본값: `""` 허용되는 값: 빈 string 또는 정규화된 Java 클래스 이름

시계열

다음 구성 설정을 사용하여 MongoDB Kafka connector가 데이터를 MongoDB time-series collection에 싱크하는 방법을 지정합니다.

time series 컬렉션과 관련된 옵션만 보려면 Kafka time-series 속성 페이지를 참조하세요.

이름

설명

timeseries.timefield

유형: string

설명:
Time Series 컬렉션의 새 문서와 연결하려는 시간 정보가 포함된 소스 데이터의 최상위 필드 이름입니다.

기본값: ""
허용 값: 빈 string 또는 BSON DateTime 값이 포함된 필드 이름

timeseries.timefield.auto.convert.date.format

유형: string

설명:
커넥터가 timeseries.timefield 설정에 지정된 필드에 포함된 소스 데이터를 변환하는 데 사용해야 하는 데이터 형식 패턴입니다.

커넥터는 데이터 형식 패턴을 Java DateTimeFormatter.ofPattern(pattern, 국가 및 언어 설정) 메서드에 전달하여 시간 필드에 대한 데이터 및 시간 변환을 수행합니다.

소스 데이터의 데이터 값에 데이터 정보만 포함된 경우 커넥터는 시간 정보를 지정된 날의 시작 시간으로 설정합니다. 데이터 값에 타임존 오프셋이 포함되지 않은 경우 커넥터는 오프셋을 UTC로 설정합니다.

기본값:

yyyy-MM-dd[['T'][ ]][HH:mm:ss[[.][SSSSSS][SSS]][ ]VV[ ]'['VV']'][HH:mm:ss[[.][SSSSSS][SSS]][ ]X][HH:mm:ss[[.][SSSSSS][SSS]]]

허용되는 값: 유효한 DateTimeFormatter 형식

timeseries.timefield.auto.convert

유형: 불리언

설명:
필드의 데이터를 BSON Date 형식으로 변환할 지 여부.

true로 설정된 경우 커넥터는 값이 숫자인 경우 유닉스 시간 이후 밀리초를 사용하고 분수 부분은 무시합니다. 값이 string인 경우 커넥터는 다음 구성에서 설정을 사용하여 날짜를 구문 분석합니다.

timeseries.timefield.auto.convert.date.format

커넥터가 값을 변환하지 못하면 원본 값을 time series 컬렉션으로 보냅니다.

기본값: false
허용 값: true 또는 false

timeseries.timefield.auto.convert.locale. Language.tag

유형: string

설명:
날짜 형식 패턴에 사용할 DateTimeFormatter 국가 및 언어 설정 언어 태그(예: "en-US").

국가 및 언어 설정에 대한 자세한 내용은 Locale의 Java SE 문서를 참조하세요.

기본값: ROOT
허용 값: 유효한 Locale 언어 태그 형식

timeseries.metafield

유형: string

설명:
관련된 Time Series 문서 그룹을 설명하기 위해 소스 데이터에서 읽어올 최상위 필드입니다.

중요: 이 필드는 _id 필드 또는 timeseries.timefield 설정에서 지정한 필드이 아닙니다.

기본값: ""
허용 값: 빈 string 또는 BsonArray를 제외한 모든 BSON 유형을 포함하는 필드 이름입니다.

timeseries.expire.after.seconds

Type: int

Description:
The number of seconds MongoDB should wait before automatically removing the time series collection data. The connector disables timed expiry when the setting value is less than 1.

To learn more, see Set up Automatic Removal for Time Series Collections in the MongoDB manual.

Default: 0
Accepted Values: An integer

timeseries. granularity

Type: string

Description:
The expected interval between subsequent measurements of your source data.

To learn more, see Set Granularity for Time Series Data in the MongoDB manual.

Optional
Default: ""
Accepted Values: "", "seconds", "minutes", "hours"

기존 컬렉션을 Time Series 컬렉션으로 변환하는 방법에 대한 예 는 기존 컬렉션을 Time Series 컬렉션으로 마이그레이션하는 방법에 대한 튜토리얼을 참조하세요.

돌아가기

시계열

모델 전략 작성