如何使用kafka連接將kafka主題下載到oracle中

我有一個包含數據的kafka主題，下面是我用來將數據下載到oracle的配置文件。如何使用kafka連接將kafka主題下載到oracle中

Sink.properties

name=ora_sink_task 
connector.class=io.confluent.connect.jdbc.JdbcSinkConnector 
tasks.max=1 
topics=person 
connection.url=jdbc:oracle:thin:@127.0.0.1:1521/XE 
connection.user=kafka 
connection.password=kafka 
auto.create=true 
insert.mode=upsert 
pk.mode=record_value 
pk.fields=id

我得到以下的日誌響應。

[2017-06-06 21:09:33,557] DEBUG Scavenging sessions at 1496504373557 (org.eclipse.jetty.server.session:347) 
[2017-06-06 21:10:03,557] DEBUG Scavenging sessions at 1496504403557 (org.eclipse.jetty.server.session:347) 
[2017-06-06 21:10:33,558] DEBUG Scavenging sessions at 1496504433558 (org.eclipse.jetty.server.session:347)

但是在oracle中沒有創建表。

來源

2017-06-06 ksingh

在將主題名稱更改爲Kafka中的PERSON並將主題= PERSON更改爲Sink.properties後，它就可以工作了。

來源

2017-06-09 11:08:35 ksingh

這是因爲卡夫卡主題名稱區分大小寫 –

謝謝@HansJespersen。但是這裏的問題與oracle有關，它需要大寫主題名來創建表。而在MySQL和Postgres中並非如此。 – ksingh

如何使用kafka連接將kafka主題下載到oracle中

回答

相關問題