EngonVHKxZ commented on issue #5900:
URL: https://github.com/apache/seatunnel/issues/5900#issuecomment-1826205169
> Yes, this feature is currently available
My usage method is as follows: using FlinkCDC to collect DML operations from
Oracle and input them into Kafka, SeaTunnel uses streaming to read CDC
operations from Kafka.
****
The following is the data format I saved to Kafka
```
{
"before": {
"ID": "0A920E5F701A275DE06011AC020000E0",
"CODE": "1",
"NAME": "1",
"VERSION": "1",
"SOURCE": "1",
"VALID_FLAG": 1,
"SORT_NO": 1,
"CREATE_OPERATOR": 1,
"MODIFY_OPERATOR": 1,
"REMARK": "1"
},
"after": {
"ID": "0A920E5F701A275DE06011AC020000E0",
"CODE": "2",
"NAME": "1",
"VERSION": "1",
"SOURCE": "1",
"VALID_FLAG": 1,
"SORT_NO": 1,
"CREATE_OPERATOR": 1,
"MODIFY_OPERATOR": 1,
"REMARK": "1"
},
"source": {
"version": "1.9.7.Final",
"connector": "oracle",
"name": "oracle_logminer",
"ts_ms": 1700881435000,
"snapshot": "false",
"db": "HELOWIN",
"sequence": null,
"schema": "LOGMINER_USER",
"table": "TEST_DICT",
"txId": "03000b00ff040000",
"scn": "3671616",
"commit_scn": "3671617",
"lcr_position": null,
"rs_id": null,
"ssn": 0,
"redo_thread": 1
},
"op": "u",
"ts_ms": 1700881435880,
"transaction": null
}
```
***
Here is my configuration file
```
env {
execution.parallelism = 1
job.mode = "STREAMING"
}
source {
Kafka {
format = debezium-json
topic = "cdc1"
bootstrap.servers = "192.168.4.18:9092"
kafka.config = {
client.id = client_1
}
}
}
sink {
Jdbc {
url="jdbc:oracle:thin:@192.168.26.129:1521:helowin",
driver="oracle.jdbc.OracleDriver",
user="logminer_user",
password="logminer_pwd",
generate_sink_sql=true,
database="HELOWIN",
table="LOGMINER_USER.TEST_DICT"
}
}
```
***
SQL statements printed in the SeaTunnel console
```
INSERT INTO "LOGMINER_USER"."TEST_DICT" ("content") VALUES (?)
```
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
