AI 에이전트의 경우: 문서 인덱스는 https://www.mongodb.com/ko-kr/docs/llms.txt에서 사용할 수 있으며, 모든 페이지의 마크다운 버전은 어떤 URL 경로에 .md를 추가하여 사용할 수 있습니다.
Docs Menu

변경 스트림 속성

다음 구성 설정을 사용하여 MongoDB Kafka 소스 커넥터로 작업할 때 변경 스트림에 대한 집계 파이프라인과 변경 스트림 커서에 대한 읽기 설정을 지정합니다.

범주별로 구성된 소스 커넥터 구성 설정 목록은 소스 커넥터 구성 속성 가이드를 참조하세요.

이름
설명

파이프라인

유형: string

설명:
변경 스트림에서 실행할 집계 파이프라인의 배열입니다. fullDocument 필드가 아닌 변경 스트림 이벤트 문서에 대해 이 설정을 구성해야 합니다.

예시는 다음과 같습니다.

[{"$match": { "$and": [{"operationType": "insert"}, {"fullDocument.eventId": 1404 }] } }]

더 많은 예시는 다음을 참조하세요:

기본값: "[]"
허용되는 값: 유효한 집계 파이프라인 단계

change.stream.full.document

Type: string

Description:
Determines what values your change stream returns on update operations.

The default setting returns the differences between the original document and the updated document.

The updateLookup setting returns the differences between the original document and updated document as well as a copy of the entire updated document at a point in time after the update.

The whenAvailable setting returns the updated document, if available.

The required setting returns the updated document and raises an error if it is not available.

For more information on how this change stream option works, see Lookup Full Document for Update Operations in the MongoDB manual.

Default: ""
Accepted Values: "", "updateLookup", "whenAvailable", or "required"

change.stream.show.expanded.events

Type: boolean

Description:
Determines if change streams notifies for DDL events such as
createIndexes and
dropIndexes
events. To learn more, see showExpandedEvents.

This setting is required to show
updateDescription.disambiguatedPaths in update events, which
clarifies changes that involve ambiguous fields. To learn more,
see disambiguatedPaths.

Default: false
Accepted Values: true or false

change.stream.full.document.before.change

Type: string

Description:
Configures the document pre-image your change stream returns on update operations. The pre-image is not available for source records published while copying existing data, and the pre-image configuration has no effect on copying.

To learn how to configure a collection to enable pre-images, see Change Streams with Document Pre- and Post-Images in the MongoDB manual.

The default setting suppresses the document pre-image.

The whenAvailable setting returns the document pre-image if it's available, before it was replaced, updated, or deleted.

The required setting returns the document pre-image and raises an error if it is not available.

Default: ""
Accepted Values: "" or "whenAvailable" or "required"

publish.full.document.only

Type: boolean

Description:
Whether to return only the fullDocument field from the change stream event document produced by any update event. The fullDocument field contains the most current version of the updated document. To learn more about the fullDocument field, see the update Event in the Server manual.

When set to true, the connector overrides the change.stream.full.document setting and sets it to updateLookup so that the fullDocument field contains updated documents.

Default: false
Accepted Values: true or false

publish.full.document.only.tombstone.on.delete

유형: 불리언

설명:
문서가 삭제될 때 삭제 표시 이벤트를 반환할지 여부입니다. 투스톤 이벤트에 null 값을 가진 삭제된 문서의 키가 포함되어 있습니다. 이 설정은 publish.full.document.only이 true인 경우에만 적용됩니다.

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

change.stream.document.key.as.key

유형: 불리언

설명:
문서 키가 있는 경우 문서 키를 소스 기록 키로 사용할지 여부입니다.

true로 설정하면 커넥터는 삭제된 문서의 키를 틀스톤 이벤트에 추가합니다. false로 설정되면 커넥터는 재개 토큰을 툼스톤 이벤트의 소스 키로 사용합니다.

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

데이터 정렬

Type: string

Description:
A JSON collation document that specifies language-specific ordering rules that MongoDB applies to the documents returned by the change stream.

Default: ""
Accepted Values: A valid collation JSON document

batch.size

유형: int

설명:
변경 스트림 커서 배치 크기입니다.

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

poll.await.time.ms

유형: long

설명:
서버가 빈 배치를 반환하기 전에 변경 스트림 커서에 보고할 새 데이터 변경 내용을 기다리는 최대 시간(밀리초)입니다.

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

poll.max.batch.size

형식: int

설명:
새 데이터에 대한 변경 스트림 커서를 폴링할 때 단일 배치에서 읽을 수 있는 최대 문서 수입니다. 이 설정을 사용하여 커넥터에서 내부적으로 버퍼링되는 데이터의 양을 제한할 수 있습니다.

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

이 페이지 평가하기

이 페이지의 내용