oracle

mnowg1ta  于 2021-06-04  发布在  Kafka
关注(0)|答案(1)|浏览(367)

我第一次创建了到oracle的jdbc接收器连接器(confluent)。下面是连接器配置。它不会创建和加载表,但是偏移量会根据日志增加,并且不会在日志中抛出错误。请提出可能的问题。
通过java制作,5个样本记录。我试过检查状态,它正在运行。

{
    "name": "ora_sink_task",
    "config": {
            "connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
            "connection.url": "jdbc:oracle:thin:@host:port/servicename",
            "connection.user": "user",
            "connection.password": "password",
            "topics": "connecttest",
            "tasks.max": "1",
            "table.name.format": "member_cbdt_sink1",
            "value.converter":"io.confluent.connect.avro.AvroConverter",
            "value.converter.schema.registry.url":"http://localhost:8081",
            "auto.create": "true"
            }
}

连接器日志:
[2019-09-09 00:34:23832]检查oracle方言是否存在表“member\u cbdt\u sink1”(io.confluent.connect.jdbc.dialect.oracledataba)的信息sedialect:492)[2019-09-09 00:34:23834]不存在使用oracle方言表“member\u cbdt\u sink1”的信息(io.confluent.connect.jdbc.dialect.oracledataba)sedialect:500) [2019-09-09 00:34:23,846]检查oracle方言是否存在表“member\u cbdt\u sink1”(io.confluent.connect.jdbc.dialect.oracledataba)的信息sedialect:492)[2019-09-09 00:34:23849]显示使用oracle方言表“member\u cbdt\u sink1”的信息(io.confluent.connect.jdbc.dialect.oracledataba)sedialect:500) [2019-09-09 00:34:24,037]将表“member\u cbdt\u sink1”的元数据信息设置为表{name='“member\u cbdt\u sink1',列=[列{'first\u name',isprimarykey=false,allowsnull=false,sqltype=clob},列{'height',isprimarykey=false,allowsnull=false,sqltype=binary\u float},列{'last\u name',isprimarykey=false,allowsnull=false,sqltype=clob},列{'age',isprimarykey=false,allowsnull=false,sqltype=number},列{'automated\u email',isprimarykey=false,allowsnull=true,sqltype=number},列{'weight',isprimarykey=false,allowsnull=false,sqltype=binary\u float}(io.confluent.connect.jdbc.util.tablede)finitions:65) [2019-09-09 00:35:13,775]info workersinktask{id=ora\u sink\u task-0}使用序号1异步提交偏移量:{connecttest-0=offsetandmetadata{offset=55,metadata=''}}(org.apache.kafka.connect.runtime.worke)rsinktask:345) [2019-09-09 01:03:13,775]info workersinktask{id=ora\u sink\u task-0}使用序列号29异步提交偏移量:{connecttest-0=offsetandmetadata{offset=60,metadata=''}}(org.apache.kafka.connect.runtime.worke)rsinktask:345)

lsmd5eda

lsmd5eda1#

它的工作原理是将table.name.format的值从小写改为大写,就像oracle查找大写一样。

相关问题