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"