Replies: 1 comment
-
|
it's ok |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
Uh oh!
There was an error while loading. Please reload this page.
Uh oh!
There was an error while loading. Please reload this page.
-
I’m currently testing and want to write data from MySQL-CDC to another database through an API. This database could be MySQL, PostgreSQL, or Oracle. However, I noticed that the official documentation specifies using JDBC for the sink. When I include "plugin_name": "JDBC" in my API, it doesn’t get recognized.
{
"env": {
"parallelism": 1,
"job.mode": "STREAMING",
"checkpoint.interval": 10000
},
"source": [
{
"plugin_name": "MySQL-CDC",
"base-url": "jdbc:mysql://192.168.11.1:3306/bz",
"username": "root",
"password": "123456",
"table-names": [
"bdczz.test"
],
"driver": "com.mysql.cj.jdbc.Driver"
}
],
"sink": [
{
"plugin_name": "JDBC",
"url": "jdbc:mysql://192.168.11.1:3306/bd",
"driver":"com.mysql.cj.jdbc.Driver",
"username": "root",
"password": "123456",
"table": "test"
}
]
}
mistake:
{
"status": "fail",
"message": "ErrorCode:[API-06], ErrorDescription:[Factory initialize failed] - Unable to create a sink for identifier 'JDBC'."
}
Beta Was this translation helpful? Give feedback.
All reactions