2016-04-11 72 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