我在rhel上有一个confluent设置,正在尝试从oracle 12c表/视图中读取数据(我两个都试过了),但它从未在使用者处创建消息。
我怀疑这与使用大容量装入器而不是一元插入器装入的表中的数据有关。我在指定的数据中确实有一个唯一的递增id列,配置加载并显示我的主题名为active/running。
有什么想法吗?
{
"name":"oracle_source_05",
"config": {
"connector.class":
"io.confluent.connect.jdbc.JdbcSourceConnector",
"key.converter": "io.confluent.connect.avro.AvroConverter",
"key.converter.schema.registry.url": "http://<host>:8081",
"value.converter": "io.confluent.connect.avro.AvroConverter",
"value.converter.schema.registry.url": "http://<host>:8081",
"connection.url": “<jdbc url>
"connection.user" : "<user>",
"connection.password" : "<pw>",
"table.whitelist": "<view name>",
"table.type" : "VIEW",
"mode": "incrementing",
"incrementing.column.name" : "<id column>",
"validate.non.null":"false",
"topic.prefix":"ORACLE-"
}
}
日志包含以下消息:
[2018-04-17 10:59:19965]调试[controller id=0]主题不在首选副本Map()中(kafka.controller.kafkacontroller)
[2018-04-17 10:59:19965]trace[controller id=0]broker 0的leader失衡比率为0.0(kafka.controller.kafkacontroller)
服务器日志:
[2018-04-18 09:24:26495]信息接受来自/127.0.0.1:39228的套接字连接(org.apache.zookeeper.server.nioservercnxnfactory)
[2018-04-18 09:24:26498]信息客户端试图在/127.0.0.1:39228建立新会话(org.apache.zookeeper.server.zookeeperserver)
[2018-04-18 09:24:26499]信息已建立会话0x162d403daed0004,协商超时30000,用于客户端/127.0.0.1:39228(org.apache.zookeeper.server.zookeeperserver)
[2018-04-18 09:24:26516]已处理sessionid的会话终止信息:0x162d403daed0004(org.apache.zookeeper.server.prerequestprocessor)
[2018-04-18 09:24:26517]info已关闭客户端/127.0.0.1:39228的套接字连接,会话ID为0x162d403daed0004(org.apache.zookeeper.server.nioservercnxn)
暂无答案!
目前还没有任何答案,快来回答吧!