我使用Confluent Kafka Connect连接到oracle,创建并启动连接器

[2016-04-10 23:23:01,998] INFO创建的连接器oracle-connect-test(org.apache.kafka.connect.cli.ConnectStandalone:82)[2016-04-10 23:23:02,629] INFO Source任务线程[WorkerSourceTask-oracle-connect-test-0,5,main]完成初始化并启动(org.apache.kafka.connect.runtime.WorkerSourceTask:342)

但是没有oracle表的主题 . 当我访问http://host:8083/connectors/oracle-connect-test时,我可以获得此连接器的配置

{“name”:“oracle-connect-test”,“config”:{“timestamp.column.name”:“MODIFIED”,“connector.class”:“io.confluent.connect.jdbc.JdbcSourceConnector”,“ mode“:”timestamp incrementing“,”incrementing.column.name“:”ID“,”topic.prefix“:”test-oracle-jdbc-“,”tasks.max“:”1“,”name“:” oracle-connect-test“,”connection.url“:”jdbc:oracle:thin:username / password @ host:port:sid“,”table.whitelist“:”USER“},”tasks“:[{”connector “:” Oracle的连接测试”, “任务”:0}]}

oracle.properties

name = oracle-connect-test connector.class = io.confluent.connect.jdbc.JdbcSourceConnector tasks.max = 1 topic.prefix = test-oracle-jdbc-connection.url = jdbc:oracle:thin:username / password @ host:port:sid table.whitelist = USER mode = timestamp incrementing timestamp.column.name = MODIFIED incrementing.column.name = ID

谢谢!