我使用匯合卡夫卡連接連接到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
謝謝!