हां, एकल संदेश रूपांतरण
का उपयोग करें , प्रति लिंक
आपने पहचान लिया। आवश्यक विषय पर तालिकाओं को मैप करने के लिए आप नियमित अभिव्यक्ति (रेगेक्स) का उपयोग कर सकते हैं। दोनों 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"