Кафка-коннект topic.prefix без имени таблицы - PullRequest
Новая
       11

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

0 голосов
/ 19 сентября 2019

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

"topic.prefix":"blah-"

1 Ответ

0 голосов
/ 19 сентября 2019

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

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