1
私はカフカのトピックをデータに持っています。次の設定ファイルは、Oracleにデータをシンクするために使用しています。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に表は作成されません。
これは、カフカのトピック名で大文字と小文字が区別されるからです。 –
ありがとう@HansJespersen。しかし、ここでの問題はオラクルであり、テーブルを作成するには大文字のトピック名が必要です。 mysqlとpostgresの間はそうではありませんでした。 – ksingh