如何使用 kafka connect 将 kafka 主题下沉到 oracle？答案

【问题标题】：How to sink kafka topic to oracle using kafka connect?如何使用 kafka connect 将 kafka 主题下沉到 oracle？
【发布时间】：2017-11-07 05:13:10
【问题描述】：

我有一个带有数据的 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中没有创建表。

【问题讨论】：

标签： oracle apache-kafka-connect

【解决方案1】：

在 Kafka 中将主题名称更改为 PERSON 并在 Sink.properties 中将 topic=PERSON 更改为有效。

【讨论】：

这是因为 Kafka 主题名称区分大小写
感谢@HansJespersen。但是这里的问题是oracle，它需要大写的主题名称来创建表。而在 mysql 和 postgres 中却不是这样。