소스 커넥터의 Kafka 주제 속성

topic.prefix

유형: string

설명:
커넥터가 변경 스트림 이벤트를 게시하는 대상 Kafka 주제 이름의 첫 번째 부분을 지정합니다. 대상 주제 이름은 topic.prefix 값과 데이터베이스 및 컬렉션 이름으로 구성되며 topic.separator 속성에 지정된 값으로 구분됩니다.

자세한 내용은 주제 명명 접두사의 예시를 참조하세요.

기본값: ""
허용되는 값: string "." "-" 및 "_"

topic.suffix

유형: string

설명:
커넥터가 변경 스트림 이벤트를 게시하는 대상 Kafka 주제 이름의 마지막 부분을 지정합니다. 대상 주제 이름은 데이터베이스 및 컬렉션 이름 뒤에 topic.suffix 값이 오고 topic.separator 속성에 지정된 값으로 구분되어 구성됩니다.

자세한 내용은 주제 명명 접미사의 예시를 참조하세요.

기본값: ""
허용되는 값: string "." "-" 및 "_"

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

유형: string

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

1. topic.prefix

2. database

3. collection

4. topic.suffix

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

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

IMPORTANT: When you use the topic.separator property, note that it doesn't affect how you define the topic.namespace.map property. The topic.namespace.map property uses MongoDB namespaces which you must always specify with a . character to separate the database and collection name.

Default: "."
Accepted Values: A string

topic.mapper

유형: string

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

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