소스 커넥터의 Kafka 주제 속성

개요

다음 구성 설정을 사용하여 MongoDB Kafka 소스 커넥터가 데이터를 게시할 Kafka 주제를 지정합니다.

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

설정

이름

설명

topic.prefix

Type: string

Description:
Specifies the first part of the destination Kafka topic name to which the connector publishes change stream events. The destination topic name is composed of the topic.prefix value followed by the database and collection names, separated by the value specified in the topic.separator property.

To learn more, see the example in Topic Naming Prefix.

Default: ""
Accepted Values: A string composed of ASCII alphanumeric characters including ".", "-", and "_"

topic.suffix

Type: string

Description:
Specifies the last part of the destination Kafka topic name to which the connector publishes change stream events. The destination topic name is composed of the database and collection names followed by the topic.suffix value, separated by the value specified in the topic.separator property.

To learn more, see the example in Topic Naming Suffix.

Default: ""
Accepted Values: A string composed of ASCII alphanumeric characters including ".", "-", and "_"

topic.namespace.map

Type: string

Description:
Specifies a JSON mapping between change stream document namespaces and topic names.

You can use to topic.namespace.map property to specify complex mappings. This property supports regex and wildcard matching.

To learn more about these behaviors and view examples, see Topic Namespace Map.

Default: ""
Accepted Values: A valid JSON object

topic.separator

유형: 문자열

설명:
connector 주제 이름을 만드는 데 사용되는 값을 연결하는 데 사용하는 문자열을 지정합니다. connector 다음 필드의 값을 다음 순서로 연결하여 구성된 이름을 가진 주제 에 레코드를 게시합니다.

topic.prefix
database
collection
topic.suffix

예시 들어, 다음 구성은 connector db 데이터베이스 의 coll 컬렉션 에서 prefix-db-coll 주제 에 변경 스트림 문서를 게시하도록 지시합니다.

topic.prefix=prefix
database=db
collection=coll
topic.separator=-

중요: topic.separator 속성 topic.namespace.map topic.namespace.map 사용하는 경우 속성 정의하는 방법에는 영향을 주지 않습니다. 속성 . 데이터베이스 와 컬렉션 이름을 구분하기 위해 항상 문자로 지정해야 하는 MongoDB 네임스페이스를 사용합니다.

기본값: "."
허용되는 값: 문자열

topic.mapper

유형: 문자열

설명:
사용자 지정 주제 매핑 로직을 정의하는 Java 클래스입니다.

기본값: com.mongodb.kafka.connect.source.topic.mapping.DefaultTopicMapper
허용되는 값: TopicMapper 클래스 구현 의 유효한 전체 클래스 이름입니다.