我使用汇合卡夫卡连接连接到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
谢谢!