Кафка-коннект topic.prefix без имени таблицы

Question

Я использую исходный соединитель jdbc, в именах моих таблиц есть специальные символы (т. Е. $), Которые приемлемы для механизма БД, но когда я запускаю kafka-connect с приведенной ниже конфигурацией, он пытается создать тему kafka с этим префиксомплюс имя таблицы, но специальные символы в имени таблицы не обязательно приемлемы для kafka.Можно ли использовать статическое целевое имя темы вместо того, чтобы полагаться на имя исходной таблицы?

"topic.prefix":"blah-"

Answer 1

В итоге я использовал преобразования kafka connect, как показано ниже, чтобы это работало.Все еще не уверен, будет ли какое-либо снижение производительности из-за SMT, но пока оно работает

            "transforms":"dropSomething",
            "transforms.dropPrefix.type":"org.apache.kafka.connect.transforms.RegexRouter",
            "transforms.dropPrefix.regex":"(.*)\\$",
            "transforms.dropPrefix.replacement":"$1"