text: -- Stream of customers
  CREATE SOURCE CONNECTOR IF NOT EXISTS customers WITH (
    'connector.class'          = 'PostgresSource',
    'name'                     = 'recipe-payment-status-check-customers',
    'kafka.api.key'            = '<my-kafka-api-key>',
    'kafka.api.secret'         = '<my-kafka-api-secret>',
    'connection.host'          = '<database-host>',
    'connection.port'          = '5432',
    'connection.user'          = 'postgres',
    'connection.password'      = '<database-password>',
    'db.name'                  = '<db-name>',
    'table.whitelist'          = 'customer_info',
    'timestamp.column.name'    = 'created_at',
    'output.data.format'       = 'JSON',
    'db.timezone'              = 'UTC',
    'tasks.max'                = '1'
  );
  
  -- Stream of payments
  CREATE SOURCE CONNECTOR IF NOT EXISTS payments WITH (
    'connector.class'          = 'PostgresSource',
    'name'                     = 'recipe-payment-status-check-payments',
    'kafka.api.key'            = '<my-kafka-api-key>',
    'kafka.api.secret'         = '<my-kafka-api-secret>',
    'connection.host'          = '<database-host>',
    'connection.port'          = '5432',
    'connection.user'          = 'postgres',
    'connection.password'      = '<database-password>',
    'db.name'                  = '<db-name>',
    'table.whitelist'          = 'payments',
    'timestamp.column.name'    = 'created_at',
    'output.data.format'       = 'JSON',
    'db.timezone'              = 'UTC',
    'tasks.max'                = '1'
  );
  
  -- Stream of aml_status
  CREATE SOURCE CONNECTOR IF NOT EXISTS aml_status WITH (
    'connector.class'          = 'PostgresSource',
    'name'                     = 'recipe-payment-status-check-aml_status',
    'kafka.api.key'            = '<my-kafka-api-key>',
    'kafka.api.secret'         = '<my-kafka-api-secret>',
    'connection.host'          = '<database-host>',
    'connection.port'          = '5432',
    'connection.user'          = 'postgres',
    'connection.password'      = '<database-password>',
    'db.name'                  = '<db-name>',
    'table.whitelist'          = 'aml_status',
    'timestamp.column.name'    = 'created_at',
    'output.data.format'       = 'JSON',
    'db.timezone'              = 'UTC',
    'tasks.max'                = '1'
  );
  
  -- Stream of funds_status
  CREATE SOURCE CONNECTOR IF NOT EXISTS funds_status WITH (
    'connector.class'          = 'PostgresSource',
    'name'                     = 'recipe-payment-status-check-funds_status',
    'kafka.api.key'            = '<my-kafka-api-key>',
    'kafka.api.secret'         = '<my-kafka-api-secret>',
    'connection.host'          = '<database-host>',
    'connection.port'          = '5432',
    'connection.user'          = 'postgres',
    'connection.password'      = '<database-password>',
    'db.name'                  = '<db-name>',
    'table.whitelist'          = 'funds_status',
    'timestamp.column.name'    = 'created_at',
    'output.data.format'       = 'JSON',
    'db.timezone'              = 'UTC',
    'tasks.max'                = '1'
  );
  