ソース コネクタのKafkaトピック プロパティ

topic.prefix

型: string

説明:
コネクタが変更ストリームイベントを公開する宛先Kafkaトピック名の最初の部分を指定します。宛先トピック名は、topic.prefixの値の後にデータベース名とコレクション名が続き、topic.separatorプロパティで指定された値で区切られます。

詳細については、トピック命名プレフィックスの例を参照してください。

デフォルト: ""
受け入れられる値: 「.」を含むASCII英数字で構成される文字列、「-」、および「_」

topic.supfix

タイプ: string

説明:
コネクタが変更ストリームイベントを公開する宛先Kafkaトピック名の最後の部分を指定します。宛先トピック名は、データベース名とコレクション名の後にtopic.suffix値が続き、topic.separatorプロパティで指定された値で区切られます。

詳細については、トピック命名サフィックスの例を参照してください。

デフォルト: ""
受け入れられる値: 「.」を含むASCII英数字で構成される文字列、「-」、および「_」

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.区切り文字

型: 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クラスの実装の有効な完全クラス名。