jdbc_source

CREATE SOURCE CONNECTOR jdbc_source WITH (
'connector.class'          = 'io.confluent.connect.jdbc.JdbcSourceConnector',
'connection.url'           = 'jdbc:postgresql://postgres:5432/camunda',
'connection.user'          = 'camunda',
'connection.password'      = 'camunda',
'topic.prefix'             = 'jdbc_',
'table.whitelist'          = 'act_hi_taskinst',
'mode'                     = 'incrementing',
'numeric.mapping'          = 'best_fit',
'incrementing.column.name' = 'id',
'key'                      = 'id',
'key.converter'            = 'org.apache.kafka.connect.converters.IntegerConverter');