You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Copy file name to clipboardExpand all lines: modules/manage/pages/iceberg/redpanda-topics-iceberg-snowflake-catalog.adoc
+60-6Lines changed: 60 additions & 6 deletions
Display the source diff
Display the rich diff
Original file line number
Diff line number
Diff line change
@@ -7,24 +7,30 @@
7
7
include::shared:partial$enterprise-license.adoc[]
8
8
====
9
9
10
+
// tag::single-source[]
11
+
10
12
This guide walks you through querying Redpanda topics as Iceberg tables in https://docs.snowflake.com/en/user-guide/tables-iceberg[Snowflake^], with AWS S3 as object storage and a catalog integration using https://other-docs.snowflake.com/en/opencatalog/overview[Open Catalog^].
11
13
12
14
== Prerequisites
13
15
16
+
ifdef::env-cloud[]
17
+
* `rpk` or familiarity with the Redpanda Cloud API to use secrets in your cluster configuration. For `rpk`, see xref:manage:rpk/rpk-install.adoc[]. For the Cloud API, you must xref:manage:api/cloud-api-authentication.adoc[authenticate] using a service account.
18
+
endif::[]
19
+
ifndef::env-cloud[]
14
20
* xref:manage:tiered-storage.adoc#configure-object-storage[Object storage configured] for your cluster and xref:manage:tiered-storage.adoc#enable-tiered-storage[Tiered Storage enabled] for the topics for which you want to generate Iceberg tables.
15
21
+
16
-
You need the S3 bucket URI, so you can configure it as external storage for Open Catalog.
22
+
You need the S3 bucket URI to configure it as external storage for Open Catalog.
23
+
endif::[]
17
24
* A Snowflake account.
18
25
* An Open Catalog account. To https://other-docs.snowflake.com/en/opencatalog/create-open-catalog-account[create an Open Catalog account^], you require ORGADMIN access in Snowflake.
19
26
* An internal catalog created in Open Catalog with your Tiered Storage AWS S3 bucket configured as external storage.
20
27
+
21
28
Follow this guide to https://other-docs.snowflake.com/en/opencatalog/create-catalog#create-a-catalog-using-amazon-simple-storage-service-amazon-s3[create a catalog^] with the S3 bucket configured as external storage. You require admin permissions to carry out these steps in AWS:
22
29
+
23
-
--
24
30
. If you don't already have one, create an IAM policy that gives Open Catalog read and write access to your S3 bucket.
25
31
. Create an IAM role and attach the IAM policy to the role.
26
32
. After creating a new catalog in Open Catalog, grant the catalog's AWS IAM user access to the S3 bucket.
27
-
--
33
+
+
28
34
* A Snowflake https://docs.snowflake.com/en/user-guide/tables-iceberg-configure-external-volume[external volume^] set up using the Tiered Storage bucket.
29
35
+
30
36
Follow this guide to https://docs.snowflake.com/en/user-guide/tables-iceberg-configure-external-volume-s3[configure the external volume with S3^]. You can use the same IAM policy as the catalog for the external volume's IAM role and user.
@@ -58,6 +64,43 @@ Grant privileges to the principal created in the previous step:
58
64
59
65
To configure your Redpanda cluster to enable Iceberg on a topic and integrate with Open Catalog:
60
66
67
+
ifdef::env-cloud[]
68
+
. xref:manage:iceberg/use-iceberg-catalogs.adoc#store-a-secret-for-rest-catalog-authentication[Store the Open Catalog client secret in your cluster] using `rpk` or the Data Plane API.
69
+
. Edit your cluster configuration to set the `iceberg_enabled` property to `true`, and set the catalog integration properties listed in the example below using `rpk` or the Control Plane API. For example, to use `rpk cluster config set`, run:
Use your own values for the following placeholders:
88
+
+
89
+
--
90
+
- `<snowflake-orgname>` and `<open-catalog-account-name>`: Your https://docs.snowflake.com/en/sql-reference/sql/create-catalog-integration-open-catalog#required-parameters[Open Catalog account URI^] is composed of these values.
91
+
+
92
+
TIP: In Snowflake, navigate to **Admin**, then **Accounts**. Click the ellipsis near your Open Catalog account name, and select **Manage URLs**. The **Current URL** contains `<snowflake-orgname>` and `<open-catalog-account-name>`.
93
+
- `<open-catalog-connection-client-id>`: The client ID of the service connection you created in an earlier step.
94
+
- `<open-catalog-client-secret-name>`: The name of the secret you created in the previous step. You must pass the secret name to the `${secrets.<secret-name>}` placeholder, not the secret value itself.
95
+
- `<open-catalog-name>`: The name of your catalog in Open Catalog.
96
+
--
97
+
+
98
+
[,bash,role=no-copy]
99
+
----
100
+
Successfully updated configuration. New configuration version is 2.
101
+
----
102
+
endif::[]
103
+
ifndef::env-cloud[]
61
104
. Edit your cluster configuration to set the `iceberg_enabled` property to `true`, and set the catalog integration properties listed in the example below. You must restart your cluster if you change this configuration for a running cluster. You can run `rpk cluster config edit` to update these properties:
Use your own values for the following placeholders:
79
122
+
80
-
--
81
123
- `<snowflake-orgname>` and `<open-catalog-account-name>`: Your https://docs.snowflake.com/en/sql-reference/sql/create-catalog-integration-open-catalog#required-parameters[Open Catalog account URI^] is composed of these values.
82
124
+
83
125
TIP: In Snowflake, navigate to **Admin**, then **Accounts**. Click the ellipsis near your Open Catalog account name, and select **Manage URLs**. The **Current URL** contains `<snowflake-orgname>` and `<open-catalog-account-name>`.
84
126
- `<open-catalog-connection-client-id>`: The client ID of the service connection you created in an earlier step.
85
127
- `<open-catalog-connection-client-secret>`: The client secret of the service connection you created in an earlier step.
86
128
- `<open-catalog-name>`: The name of your catalog in Open Catalog.
87
-
--
88
129
+
89
130
[,bash,role=no-copy]
90
131
----
91
132
Successfully updated configuration. New configuration version is 2.
92
133
----
93
134
94
135
. You must restart your cluster so that the configuration changes take effect.
136
+
endif::[]
95
137
96
-
. Enable the integration for a topic by configuring the topic property `redpanda.iceberg.mode`. This mode creates an Iceberg table for the topic consisting of two columns, one for the record metadata including the key, and another binary column for the record's value. See xref:manage:iceberg/about-iceberg-topics.adoc#enable-iceberg-integration[Enable Iceberg integration] for more details on Iceberg modes. The following examples show how to use xref:get-started:rpk-install.adoc[`rpk`] to either create a new topic, or alter the configuration for an existing topic, to set the Iceberg mode to `key_value`.
138
+
. Enable the integration for a topic by configuring the topic property `redpanda.iceberg.mode`. This mode creates an Iceberg table for the topic consisting of two columns: one for the record metadata including the key, and another binary column for the record's value. See xref:manage:iceberg/about-iceberg-topics.adoc#enable-iceberg-integration[Enable Iceberg integration] for more details on Iceberg modes.
139
+
ifdef::env-cloud[]
140
+
+
141
+
Use any of the following to set `redpanda.iceberg.mode`:
142
+
+
143
+
* `rpk`. See the following examples to run `rpk topic` commands.
144
+
* The Cloud UI. Navigate to *Topics* to create a new topic and specify `redpanda.iceberg.mode` in *Additional Configuration*, or edit an existing topic under the topic's *Configuration* tab.
145
+
* The Data Plane API to xref:api:ROOT:cloud-dataplane-api.adoc#post-/v1/topics[create a new topic] or xref:api:ROOT:cloud-dataplane-api.adoc#patch-/v1/topics/-topic_name-/configurations[update a property for an existing topic]. Specify the key-value pair for `redpanda.iceberg.mode` in the request body.
146
+
endif::[]
147
+
+
148
+
The following examples show how to use `rpk` to create a new topic or alter the configuration for an existing topic, setting the Iceberg mode to `key_value`.
97
149
+
98
150
.Create a new topic and set `redpanda.iceberg.mode`:
99
151
[,bash]
@@ -218,3 +270,5 @@ Your query results should look like the following:
0 commit comments