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

topic.prefix

タイプ: string


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

トピックの命名プレフィックス

""
の例を参照してください。デフォルト: 許容値: "."、"-"、"_" などの ASCII 英数字文字で構成される string

topic.supfix

タイプ: string


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

トピックの命名サフィックス

""
の例を参照してください。デフォルト: 許容値: "."、"-"、"_" などの ASCII 英数字文字で構成される string

topic.namespace.map

タイプ: string


説明:変更ストリームドキュメントの名前空間とトピック名の間のJSONマッピングを指定します。複雑なマッピングを指定するには、

をtopic.namespace.map プロパティに使用します。このプロパティは、正規表現とワイルドカードの一致をサポートします。これらの動作と表示例について詳しくは、「

トピック名前空間マップ

」を参照してください。デフォルト:""
許容値: 有効なJSONオブジェクト

topic.区切り文字

タイプ: string 説明:トピックの名前を作成するために使用される値を連結するためにコネクタが使用する 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=-

重要: topic.separatorプロパティを使用する場合、 プロパティtopic.namespace.map の定義方法には影響しないことに注意してください。topic.namespace.map プロパティはMongoDB名前空間を使用します。この名前空間は、データベースとコレクション名を区切るために常に 文字で指定する必要があります。デフォルト:.

"."
許容値: string

topic.mapper

タイプ: string




説明:com.mongodb.kafka.connect.source.topic.mapping.DefaultTopicMapper
カスタムトピックマッピング ロジックを定義するJavaクラス。デフォルト: 許容値: ToicMapperクラスの実装の有効な完全なクラス名。