Kafka JDBC Sink Connector - Oracle

Question

我第一次创建到oracle的jdbc接收器连接器(汇合)。下面是连接器配置。它没有创建和加载表，但是偏移量随着日志的增加而增加，并且日志中没有抛出错误。请提出可能的问题。

通过java生成，5个样本记录。我尝试了 curl 来检查状态，它正在运行。

{
    "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]INFO正在检查Oracle方言表“member_cbdt_sink1”是否存在（io.confluent.connect.jdb.dialize.OracleDatabaseDialect:492）[2019-09.09 00:34:33834]INFO正在使用Oracle方言表表“member _cbdt_sink1”不存在（io.canfluent.cannect.jdb.Dialize.OOracleDatabaseDialect:500）[201909-09 00:34:23846]INFO正在查看Oracle方言表是否存在“member_cbdt_sink1”（io.confluent.connect.jdbd.dialection.OracleDatabaseDialect:492）〔2019-09-09 00:34:23849〕INFO使用Oracle方言表“member_cbdt_sink1”存在（io.convluent.coconnect.jdbd.Dialection.OracleDatabase dialect:500）〔2019-09-09 00:34:24037〕INFO将表“member _cbdt_sink1”的元数据设置为表｛name='“memberc_bdt_sink 1”'，columns＝[Column｛‘first_name‘，isPrimaryKey＝false，allowsNull＝false，sqlType＝CLOB｝，列｛‘height‘，isPrimyKey＝false，allowsNull=false，sqlType=BINARY_FLOAT｝，栏｛‘last_name‘，is PrimaryKey=false，allows Null＝false、sqlType＝CLOB｝、列｛’age‘，isPrimaryKey＝false、allowsNull=false、sqlType=NUMBER｝，列｛'weight'，isPrimaryKey=false，allowsNull=false，sqlType=BINARY_FLOAT｝]｝（io.confluent.connect.jdbc.util.TableDefinitions:65）[2019-09-09 00:35:13775]INFO WorkerLinkTask｛id=ora_sink_task-0｝使用序列号1异步提交偏移量：｛connecttest-0=OffsetAndMetadata｛offset=55，元数据=“”｝（org.apache.cafka.connect.runtime.WorkerLinkTask:345）[201909-09 01:03:13775]信息WorkerLinkTask｛id＝ora_sink_task-0｝使用序列号29异步提交偏移量：｛connecttest-0＝OffsetAndMetadata｛offset＝60，metadata＝“”｝｝（org.apache.kafka.connect.runtime.WorkerLinkTask:345）

Answer 1

它通过将table.name.format的值从小写改为大写来工作，就像Oracle查找大写一样。