-
Notifications
You must be signed in to change notification settings - Fork 132
Description
From articles such as
https://help.aiven.io/en/articles/3416789-jdbc-source-connector-with-postgresql
a minimum working Postsgres JDBC Connector is like:
{
"name": "jdbc_source_connector_postgresql_01",
"config": {
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"connection.url": "jdbc:postgresql://localhost:5432/demo",
"connection.user": "postgres",
"connection.password": "root",
"topic.prefix": "postgres-01-",
"poll.interval.ms" : 3600000,
"mode":"bulk"
}
}
or
{
"connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
"mode": "timestamp+incrementing",
"timestamp.column.name": "modified",
"incrementing.column.name": "id",
"topic.prefix": "jdbc_var_cols-",
"tasks.max": "1",
"poll.interval.ms": "1000",
"query": "SELECT id,name,email,department,modified FROM test",
"connection.url": "jdbc:mariadb://127.0.0.1:3306/connect_test?user=root&password=confluent"
}
Why are all the following required fields here before I can be allowed to CREATE a JDBC Source Connector?
"key.converter" : Invalid value for configuration key.converter: Class could not be found.
"value.converter" : Invalid value for configuration value.converter: Class could not be found.
"header.converter" : Invalid value for configuration header.converter: Class could not be found.
"table.whitelist" : Invalid value for configuration numeric.mapping: Invalid enumerator
"table.blacklist" : Invalid value for configuration numeric.mapping: Invalid enumerator
"numeric.mapping" : Invalid value for configuration numeric.mapping: Invalid enumerator
"incrementing.column.name" : Query mode must be specified
"timestamp.column.name" : Query mode must be specified
"timestamp.initial" : Invalid value for configuration timestamp.initial: Not a number of type LONG
"timestamp.initial" : Query mode must be specified
"validate.non.null" : Query mode must be specified
Config "key.converter" requires a value
Config "value.converter" requires a value
Config "header.converter" requires a value
Config "transforms" requires a value
Config "connection.user" requires a value
Config "connection.password" requires a value
Config "table.whitelist" requires a value
Config "table.blacklist" requires a value
Config "catalog.pattern" requires a value
Config "schema.pattern" requires a value
Config "numeric.mapping" requires a value
Config "dialect.name" requires a value
Config "mode" requires a value
Config "incrementing.column.name" requires a value
Config "timestamp.column.name" requires a value
Config "timestamp.initial" requires a value
Config "query" requires a value
Config "query.suffix" requires a value