kafka-connect-oracle
kafka-connect-oracle copied to clipboard
erdemcer
Kafka Source Connector For Oracle
./bin/connect-distributed.sh ./config/connect-distributed-Oracle.properties ./config/OracleSourceConnector.properties 启动kafka服务会出现这种错误 Connection to node -1 (localhost/127.0.0.1:9092) could not be established. Broker may not be available. (org.apache.kafka.clients.NetworkClient:725)。貌似只有指定config/server.properties才能正常启动。这个端口都起不来。请问是什么问题哈
the error is this： ERROR SQL error during poll (com.ecer.kafka.connect.oracle.OracleSourceTask:277) java.sql.SQLRecoverableException: Closed Connection: next at oracle.jdbc.driver.InsensitiveScrollableResultSet.next(InsensitiveScrollableResultSet.java:570) at com.ecer.kafka.connect.oracle.OracleSourceTask.poll(OracleSourceTask.java:227) at org.apache.kafka.connect.runtime.WorkerSourceTask.poll(WorkerSourceTask.java:245) at org.apache.kafka.connect.runtime.WorkerSourceTask.execute(WorkerSourceTask.java:221) at org.apache.kafka.connect.runtime.WorkerTask.doRun(WorkerTask.java:177) at org.apache.kafka.connect.runtime.WorkerTask.run(WorkerTask.java:227) at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511) at java.util.concurrent.FutureTask.run(FutureTask.java:266)...
Hi Erdemcer, This is not a bug. I would like to know how we can change capture only specific columns in a table in Database. Thanks in advance for your...
Hi, This is not a bug. I juts would like to know if the change data capture that is written to a Kafka topic conforms to any schema like AVRO....
Currently JSQLParser parses SQL and returns pre-escaped strings. When sending this across Kafka to replicate data it causes double escaping in Oracle, by default at least, and can exceed column...
ORA-01292: no log file has been specified for the current LogMiner session ORA-06512: at "SYS.DBMS_LOGMNR", line 58 ORA-06512: at line 1 what's the matter?
why? 2020-05-12 09:45:12,629] ERROR Error during poll on topic demo SQL :update "XTHIS"."IPI_REGISTRATION" set "TOTAL_CHARGE_AMT" = 2655.28, "TOTAL_PREPAY_AMT" = 2000 where "ID" = 'e24af00b369480817db9' and "TOTAL_CHARGE_AMT" = 2655.28 and "TOTAL_PREPAY_AMT"...
Hi There, I am playing with this wonderful tool, and found one thing with clob data type column update. I first created a table create table tab2(id int not null,...
Hi, There is no data output (it is null in JSON) for LOB column after I issue a sql insert/update operation. SQL_REDO field is correct for LOB column. Could you...