2016-04-11 75 views
0

我使用匯合卡夫卡連接連接到oracle,連接器被創建並啓動匯合卡夫卡連接爲Oracle

[2016年4月10日23:23:01998] INFO創建連接器Oracle的連接 - 測試(org.apache.kafka.connect.cli.ConnectStandalone:82)

[2016-04-10 23:23:02,629]信息源任務線程[WorkerSourceTask-oracle-connect-test-0,5,main ]完成初始化並啓動(org.apache.kafka.connect.runtime.WorkerSourceTask:342)

,但不存在oracle表的主題。 當我訪問http://host:8083/connectors/oracle-connect-test

{ 「名」 我能得到這個連接器的配置: 「Oracle的連接測試」,

「配置」:{

「timestamp.column。名 「的」 修飾」,

「connector.class」: 「io.confluent.connect.jdbc.JdbcSourceConnector」,

「模式」: 「時間戳+增量」,

「incrementing.column.name」: 「ID」,

「topic.prefix」: 「測試甲骨文JDBC-」,

「tasks.max」: 「1」,

「名稱」: 「Oracle的連接測試」, 「

connection.url 」:「 JDBC:預言:瘦:用戶名/密碼@主機:端口:SID」,

「table.whitelist 「:」USER「},

「任務」:[{ 「連接器」: 「Oracle的連接測試」, 「任務」:0}]}

oracle.properties

名稱= Oracle的連接測試

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

tasks.max = 1

topic.prefix =測試甲骨文JDBC-

connection.url = JDBC:預言:瘦:用戶名/密碼@主機:端口:SID

table.whitelist = USER

模式=時間戳+遞增

timestamp.column.name =改進

incrementing.column.name = ID

謝謝!

回答

0

有時我和你有一樣的事情發生。然後,我將嘗試刪除/ tmp/kafka-logs和/ tmp/zookeeper,然後重新啓動zookeeper和kafka-server,架構註冊表。然後有時候就可以了。但有時它也會造成這個話題的錯誤。我認爲與oracle的融合連接不穩定,並且在kafka-connect-jdbc代碼中存在一些錯誤。請參考網站https://groups.google.com/forum/#!topic/confluent-platform/oFaXfjMJ8Co