本文介紹了如何使用kafka connect將kafka主題下沉到oracle?的處理方法，對(duì)大家解決問題具有一定的參考價(jià)值，需要的朋友們下面隨著小編來一起學(xué)習(xí)吧！
問題描述
我有一個(gè)包含數(shù)據(jù)的 kafka 主題，以下是我用來將數(shù)據(jù)接收到 oracle 的配置文件.
I have a kafka topic with data, following is config file I am using to sink data to oracle.
Sink.properties
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
我在日志中收到以下響應(yīng).
I am getting following response in logs.
[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中沒有創(chuàng)建表.
But no table is created in oracle.
推薦答案
在 Kafka 中將主題名稱更改為 PERSON 并且在 Sink.properties 中將主題名稱更改為 PERSON 后，它起作用了.
After changing topic name to PERSON in Kafka and topics=PERSON in Sink.properties it worked.
這篇關(guān)于如何使用kafka connect將kafka主題下沉到oracle?的文章就介紹到這了，希望我們推薦的答案對(duì)大家有所幫助，也希望大家多多支持html5模板網(wǎng)！
【網(wǎng)站聲明】本站部分內(nèi)容來源于互聯(lián)網(wǎng),旨在幫助大家更快的解決問題，如果有圖片或者內(nèi)容侵犯了您的權(quán)益，請(qǐng)聯(lián)系我們刪除處理，感謝您的支持！