Сливной Кафка Connect для Oracle

Question

Я использую Confluent Кафка Connect для подключения к оракулу, разъем создан и начал

[2016-04-10 23: 23: 01998] INFO Создан разъем оракул-замыкающийся test (org.apache.kafka.connect.cli.ConnectStandalone: ​​82)

[2016-04-10 23: 23: 02,629] INFO Задача источника Thread [WorkerSourceTask-oracle-connect-test-0,5, main ] завершена инициализация и запуск (org.apache.kafka.connect.runtime.WorkerSourceTask: 342)

, но не существует тем для таблиц оракула. я могу получить конфигурацию этого соединителя, когда доступ http://host:8083/connectors/oracle-connect-test

{ "имя": "Оракул-подключения-тест",

"конфигурации": {

«timestamp.column. назвать ":" МОДИФИЦИРОВАННЫМ»,

"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",

"режим": "метка времени + приращение",

"incrementing.column.name": "ИД",

"topic.prefix": "тест-оракула-jdbc-",

"tasks.max": "1",

"имя": "оракул-подключения-тест", "

connection.url ":": оракул JDBC: тонкий: имя пользователя/пароль @ хост: порт: Sid",

«table.whitelist ":" ПОЛЬЗОВАТЕЛЬ "},

"задача": [{ "соединитель": "Оракул-Connect-тест", "задача": 0}]}

oracle.properties

имя = оракул-Connect-тест

connector.class = io.confluent.connect.jdbc.JdbcSourceConnector

tasks.max = 1

topic.prefix = тест-оракул-jdbc-

connection.url = JDBC: оракул: тонкий: имя пользователя/пароль @ хост: порт: с.и.д.

table.whitelist = USER Режим

= отметка времени + приращением

timestamp.column.name = ОБНОВЛЕНО

incrementing.column.name = ID

Спасибо!

Answer 1

Иногда у меня то же самое происходит с вами. Затем я попробую удалить/tmp/kafka-logs и/tmp/zookeeper и перезапустить zookeeper и kafka-server, schema-registry.Then иногда это нормально. Но иногда это также ложно создает тему. Я думаю, что конфлюентная связь с oracle нестабильна и имеет некоторые ошибки в коде kafka-connect-jdbc. Пожалуйста, обратитесь на сайт https://groups.google.com/forum/#!topic/confluent-platform/oFaXfjMJ8Co