Kafka connect JDB C раковина с именем таблицы, содержащим "." - PullRequest
Новая
       4

Kafka connect JDB C раковина с именем таблицы, содержащим "."

0 голосов
/ 12 февраля 2020

Я пытаюсь построить kafka connect jdb c Разъем приемника. Проблема заключается в том, что имя таблицы базы данных содержит точку, и при создании соединителя процесс разбивает имя таблицы на две части, что приводит к необнаруженной таблице базы данных. Я пробовал несколько вещей, чтобы экранировать точку, чтобы она могла быть прочитана как строка в имени таблицы, но ничего не получалось ..

Вот фактическое имя:

"table.name.format" : "Bte3_myname.centrallogging",

вот ошибка:

Причина: org. apache .kafka.connect.errors.ConnectException: Таблица \ "Bte3_myname \". \ " centrallogrecord \ "отсутствует.

Вот мой конфигурационный файл: 

{
    "name": "jdbc-connect-central-logging-sink",
    "config": 
    {
        "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
        "tasks.max": "3",
        "topics": "central_logging",

        "connection.url": "...",         
        "connection.user": "...",
        "connection.password": "...",
        "table.name.format":"Bte3_myname.centrallogging",
        "pk.mode": "kafka",

        "auto.create": "false",
        "auto.evolve": "false"
    }
}

Может быть, у кого-нибудь есть идеи о том, как правильно проанализировать этот файл в конфигурационном файле?

Спасибо много!

...