Use the CREATE CONNECTION
command to create a reusable catalog for connector parameters.
CREATE CONNECTION
command creates a reusable connection configuration that can be referenced when creating sources, sinks, or tables. Currently supported connection types are Kafka, Schema Registry, and Iceberg.
iceberg
connection.Parameter or clause | Description |
---|---|
type | Required. The type of connection. Supported values: kafka , schema_registry , iceberg . |
secret_name | Use the SECRET keyword to reference secrets, allowing sensitive information to be stored securely and referenced in the connection configuration. Changes to the secret are automatically applied, so there’s no need to alter the connection. |
Click to see all supported properties for Kafka connection.
properties.bootstrap.server
: The Kafka bootstrap server addresses.properties.security.protocol
properties.ssl.endpoint.identification.algorithm
properties.ssl.ca.location
properties.ssl.ca.pem
properties.ssl.certificate.location
properties.ssl.certificate.pem
properties.ssl.key.location
properties.ssl.key.pem
properties.ssl.key.password
properties.sasl.mechanism
properties.sasl.username
properties.sasl.password
properties.sasl.kerberos.service.name
properties.sasl.kerberos.keytab
properties.sasl.kerberos.principal
properties.sasl.kerberos.kinit.cmd
properties.sasl.kerberos.min.time.before.relogin
properties.sasl.oauthbearer.config
privatelink.targets
privatelink.endpoint
aws.region
endpoint
aws.credentials.access_key_id
aws.credentials.secret_access_key
aws.credentials.session_token
aws.credentials.role.arn
aws.credentials.role.external_id
Click to see all supported properties for Schema Registry.
Property name | Description |
---|---|
schema.registry | The base URL of the Schema Registry service. |
schema.registry.username | The username for authenticating to the Schema Registry service. |
schema.registry.password | The password for authenticating to the Schema Registry service. |
Click to see all supported properties for Iceberg connection.
Property name | Description |
---|---|
catalog.type | Type of the Iceberg catalog. |
s3.region | AWS S3 region. |
s3.endpoint | AWS S3 endpoint. |
s3.access.key | AWS S3 access key. |
s3.secret.key | AWS S3 secret key. |
gcs.credential | Google Cloud Storage credential. |
azblob.account_name | The Azure Storage account name. |
azblob.account_key | The Azure Storage account key associated with the account name |
azblob.endpoint_url | The full endpoint URL of the Azure Blob service. |
warehouse.path | Path of the Iceberg warehouse, applicable only in storage catalog. |
catalog.name | Name of the catalog, optional for storage catalog, required for others. |
catalog.uri | URI of the Iceberg catalog, applicable only in rest catalog. |
catalog.credential | Credential for accessing Iceberg catalog, applicable only in rest catalog. |
catalog.token | Token for interacting with rest catalog server. |
catalog.oauth2_server_uri | OAuth2 token endpoint URI, applicable only in rest catalog. |
catalog.scope | Additional OAuth2 scope for accessing the Iceberg catalog, applicable only in rest catalog. |
catalog.rest.signing_region | The signing region when signing requests to the rest catalog. |
catalog.rest.signing_name | The signing name when signing requests to the rest catalog. |
catalog.rest.signing_region | Specify whether to use SigV4 for signing requests to the rest catalog. |
s3.path.style.access | Enables path-style access for AWS S3. |
catalog.jdbc.user | JDBC user for catalog access. |
catalog.jdbc.password | JDBC password for catalog access. |
enable_config_load | Controls whether configuration is loaded from environment variables. Set to true will load warehouse credentials from environment variables. Only supported in self-hosted environments. |
CREATE CONNECTION
command in RisingWave to create an AWS PrivateLink connection referencing the endpoint service created. Here is an example of creating an AWS PrivateLink connection.CREATE SOURCE/TABLE
command to create a Kafka source with PrivateLink connection. For more details, see Create source with AWS PrivateLink connection.CREATE SINK
command to create a Kafka sink with PrivateLink connection. For more details, see Create sink with AWS PrivateLink connection.