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"