jdbc_source_connector_postgresql_01.json

{
  "connector.class": "io.confluent.connect.jdbc.JdbcSourceConnector",
  "connection.url": "jdbc:postgresql://your-pagila-database-url.us-east-1.rds.amazonaws.com:5432/pagila",
  "connection.user": "your-username",
  "connection.password": "your-password",
  "topic.prefix": "pagila.public.alt.",
  "poll.interval.ms": 5000,
  "mode": "timestamp",
  "timestamp.column.name": "last_update",
  "catalog.pattern": "public",
  "table.whitelist": "address",
  "numeric.mapping": "best_fit",
  "transforms": "createKey,extractInt,InsertTopic,InsertSourceDetails",
  "transforms.createKey.type": "org.apache.kafka.connect.transforms.ValueToKey",
  "transforms.createKey.fields": "address_id",
  "transforms.extractInt.type": "org.apache.kafka.connect.transforms.ExtractField$Key",
  "transforms.extractInt.field": "address_id",
  "validate.non.null": "false",
  "transforms.InsertTopic.type": "org.apache.kafka.connect.transforms.InsertField$Value",
  "transforms.InsertTopic.topic.field": "message_topic",
  "transforms.InsertSourceDetails.type": "org.apache.kafka.connect.transforms.InsertField$Value",
  "transforms.InsertSourceDetails.static.field": "message_source",
  "transforms.InsertSourceDetails.static.value": "pagila"
}