Skip to content

Instantly share code, notes, and snippets.

@SumonMSelim
Last active March 16, 2022 18:59
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save SumonMSelim/202457c5af8337778ddd1e37f71f4666 to your computer and use it in GitHub Desktop.
Save SumonMSelim/202457c5af8337778ddd1e37f71f4666 to your computer and use it in GitHub Desktop.
{
"connector.class": "io.confluent.connect.jdbc.JdbcSinkConnector",
"transforms.TimestampConverter1.target.type": "Timestamp",
"transforms.TimestampConverter2.target.type": "Timestamp",
"connection.password": "xxxxxxxxx",
"transforms": "RenameField1,RenameField2,TimestampConverter1,TimestampConverter2",
"transforms.TimestampConverter1.type": "org.apache.kafka.connect.transforms.TimestampConverter$Value",
"transforms.RenameField1.type": "org.apache.kafka.connect.transforms.ReplaceField$Value",
"transforms.TimestampConverter2.type": "org.apache.kafka.connect.transforms.TimestampConverter$Value",
"insert.mode": "upsert",
"transforms.RenameField1.renames": "shipper_id:organization_id,shipper_hub_id:organization_hub_id",
"dialect.name": "MySqlDatabaseDialect",
"table.name.format": "delivery_relation",
"topics": "dev-mdm.mdm_dev.delivery_relation",
"transforms.TimestampConverter2.field": "expiration_date",
"transforms.TimestampConverter1.format": "yyyy-MM-dd",
"transforms.TimestampConverter2.format": "yyyy-MM-dd",
"fields.whitelist": "id,shipper_id,shipper_hub_id,target_country_id,last_mile_carrier_id,last_mile_carrier_hub_id,activation_date,expiration_date",
"key.converter.schemas.enable": "true",
"value.converter.schema.registry.url": "http://10.201.75.200:8081",
"delete.enabled": "true",
"transforms.TimestampConverter1.field": "activation_date",
"connection.user": "Admin",
"value.converter.schemas.enable": "true",
"name": "dev-mdm.spdb-sink.delivery_relation-connector",
"connection.url": "jdbc:mysql://xyz.eu-central-1.rds.amazonaws.com:3306/xyz",
"transforms.RenameField2.type": "org.apache.kafka.connect.transforms.ReplaceField$Value",
"transforms.RenameField2.whitelist": "id,organization_id,organization_hub_id,target_country_id,last_mile_carrier_id,last_mile_carrier_hub_id,activation_date,expiration_date",
"pk.mode": "record_key",
"key.converter.schema.registry.url": "http://0.0.0.0:8081",
"pk.fields": "id"
}
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment