Mysql
 sql >> Cơ Sở Dữ Liệu >  >> RDS >> Mysql

Trong Debezium có thể định cấu hình ánh xạ chủ đề table_name => kafka không?

Có, hãy sử dụng Chuyển đổi thư đơn , theo liên kết bạn đã xác định. Bạn có thể sử dụng biểu thức chính quy (regex) để ánh xạ các bảng theo chủ đề cần thiết. Cả io.debezium.transforms.ByLogicalTableRouter hoặc org.apache.kafka.connect.transforms.RegexRouter nên làm thủ thuật. Có một ví dụ về cái sau trong bài đăng này ở đây :

"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. Làm thế nào để cập nhật trên tầng trong MySQL?

  2. Cx-Freeze:Showwarning AttributeError:Đối tượng 'NoneType' không có thuộc tính 'write'

  3. Cách tốt nhất để xử lý các phiên cho một trang PHP trên nhiều máy chủ là gì?

  4. Làm thế nào để sử dụng chuỗi PHP trong truy vấn mySQL LIKE?

  5. Làm cách nào để đổi tên tệp đã tải lên trước khi lưu vào thư mục?