如何使用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中没有创建表。

答

在将主题名称更改为Kafka中的PERSON并将主题= PERSON更改为Sink.properties后，它就可以工作了。

这是因为卡夫卡主题名称区分大小写 –

谢谢@HansJespersen。但是这里的问题与oracle有关，它需要大写主题名来创建表。而在MySQL和Postgres中并非如此。 – ksingh

如何使用kafka连接将kafka主题下载到oracle中

相关推荐