kafka-connect-oracle
kafka-connect-oracle copied to clipboard
erdemcer
Kafka Source Connector For Oracle
like: jdbc:oracle:thin:@(DESCRIPTION = (ADDRESS_LIST = (ADDRESS = (PROTOCOL = TCP)(HOST =
Hi, I am using confluent and kafka-connect-oracle and i can see schema content by using schema registry api such as "curl -X GET http://localhost:8081/schemas/ids/44" : `{"subject":"TEST.KAFKAUSER.TEST-value","version":1,"id":44,"schema":"{\"type\":\"record\",\"name\":\"row\",\"namespace\":\"test.kafkauser.test\",\"fields\":[{\"name\":\"SCN\",\"type\":\"long\"},{\"name\":\"SEG_OWNER\",\"type\":\"string\"},{\"name\":\"TABLE_NAME\",\"type\":\"string\"},{\"name\":\"TIMESTAMP\",\"type\":{\"type\":\"long\",\"connect.version\":1,\"connect.name\":\"org.apache.kafka.connect.data.Timestamp\",\"logicalType\":\"timestamp-millis\"}},{\"name\":\"SQL_REDO\",\"type\":\"string\"},{\"name\":\"OPERATION\",\"type\":\"string\"},{\"name\":\"data\",\"type\":[\"null\",{\"type\":\"record\",\"name\":\"value\",\"namespace\":\"\",\"fields\":[{\"name\":\"ID\",\"type\":[\"null\",\"double\"],\"default\":null},{\"name\":\"NAME\",\"type\":[\"null\",\"string\"],\"default\":null}],\"connect.name\":\"value\"}],\"default\":null},{\"name\":\"before\",\"type\":[\"null\",\"value\"],\"default\":null}],\"connect.name\":\"test.kafkauser.test.row\"}","deleted":false}` However this schema cannot...
Hi: This is a very useful project based on logminer. My data is Oracle 12c release 2. In the SQL_REDO=insert statement i get EMPTY_CLOB for the CLOB data type column....
After modifying the table structure of the source database, DDL statements are captured normally, but continue to test the DML statements and report an error if they are invalid Is...
Hello, I have an issue, it seems that everything is correctly configured, but there are any message in the topic, i'm working with an Oracle 12c Database, but doesn't have...
Hello! i'am using Kafka with Kubernetes (https://github.com/confluentinc/cp-helm-charts) And i configured the plugin with success because the Kafka Connect process executes with no error and the status is running! (When i...
hi，I have a problem！ **This is my connector configuration：** { connector.class: "com.ecer.kafka.connect.oracle.OracleSourceConnector", reset.offset: "true", db.hostname: "192.168.1.176", tasks.max: "1", db.user.password: "test123456", table.blacklist: "", table.whitelist: "TEST1.T1", db.user: "test1", start.scn: **"0",** db.port: "1521",...
Hi， How to specify the key that Kafka accepts each message? Thanks.
