sql >> データベース >  >> RDS >> Mysql

Debeziumでtable_name=>kafkaトピックマッピングを構成することは可能ですか?

    はい、シングルメッセージ変換 を使用してください 、リンク ごと あなたが特定した。正規表現(regex)を使用して、テーブルを必要なトピックにマップできます。両方のio.debezium.transforms.ByLogicalTableRouter またはorg.apache.kafka.connect.transforms.RegexRouter トリックを行う必要があります。後者の例がありますこの投稿はこちら :

    "transforms":"dropPrefix",  
    "transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",  
    "transforms.dropPrefix.regex":"DC1-TEST-(.*)",  
    "transforms.dropPrefix.replacement":"$1"
    



    1. より大きなSQLファイルをMySQLにインポートする

    2. Puppetを使用したBarmanの自動化:it2ndq / barman(パート1)

    3. 日付列のMySQL条件付きORDERBYASC / DESC

    4. XAMPPを介してMySQLを使用するにはどうすればよいですか?