Mysql
 sql >> Teknologi Basis Data >  >> RDS >> Mysql

Apakah mungkin di Debezium untuk mengonfigurasi table_name => pemetaan topik kafka?

Ya, gunakan Transformasi Pesan Tunggal , per tautan Anda mengidentifikasi. Anda dapat menggunakan ekspresi reguler (regex) untuk memetakan tabel ke topik yang diperlukan. Keduanya io.debezium.transforms.ByLogicalTableRouter atau org.apache.kafka.connect.transforms.RegexRouter harus melakukan trik. Ada contoh yang terakhir di pos ini di sini :

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



  1. Database
  2.   
  3. Mysql
  4.   
  5. Oracle
  6.   
  7. Sqlserver
  8.   
  9. PostgreSQL
  10.   
  11. Access
  12.   
  13. SQLite
  14.   
  15. MariaDB
  1. Bagaimana cara memilih baris ke-n dalam tabel database SQL?

  2. Cara mengubah massal MySQL Triggers DEFINER

  3. Menghubungkan ke DB dari Ekstensi Chrome?

  4. Gagal menemukan direktori data yang valid. Instalasi biner generik MySQL

  5. kesalahan mySQL:#1248 - Setiap tabel turunan harus memiliki alias sendiri