-
Enhancement
-
Resolution: Done
-
Major
-
None
-
None
-
False
-
False
-
The default TopicSelector routes messages to the topics named like <database>.<schema>.<table>. If a different routing logic is required, an org.apache.kafka.connect.transforms.RegexRouter SMT is usually added to the connector configuration.
The challenge is that the object name separator in the default topic selector (the dot) may also be part of a database object name.
In multi-tenant environments, where the object names aren't restricted by a naming convention, a table named accounts.bak may break the logic implemented in an SMT that doesn't account for a dot in the object name.
In cases like this, it would be more reliable to use a custom topic selector rather than a regex-based SMT.