모든 싱크 커넥터 구성 속성

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
허용되는 값: 정수

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
허용 값: 유효한 노드 수

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

유형: string

설명:
커넥터가 대량 쓰기 (Bulk Writes)에 사용해야 할 WriteModelStrategy 을(를) 지정하는 클래스입니다.

자체 전략을 만드는 방법에 대해 자세히 알아보려면
사용자 지정 쓰기 (write) 모델 전략을 참조하세요.

기본값:

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

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

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

유형: int

설명:
MongoDB가 time series 컬렉션 데이터를 자동으로 제거하기 전에 대기해야 하는 초 수입니다. 설정 값이 1보다 작으면 커넥터가 시간 만료를 비활성화합니다.

자세한 내용은 MongoDB 매뉴얼의 Time Series 컬렉션에 대한 자동 제거 설정 을 참조하세요.

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

timeseries. granularity

유형: string

설명:
소스 데이터의 연속 측정 간의 예상 간격입니다.

자세한 내용은 MongoDB 설명서의 Time Series 데이터용 세분성 설정 을 참조하세요.

선택 사항
기본값: ""
허용 값: "", "seconds", "minutes", "hours"