vastperu.blogg.se

Use the Avro parser, version 1.8.2 (or higher), available from. ALTER USER kafka_connector_user_1 SET DEFAULT_ROLE = kafka_connector_role_1 If you encounter an 'Insufficient privileges' error, verify the role that has the OWNERSHIP privilege on the user. GRANT ROLE kafka_connector_role_1 TO USER kafka_connector_user_1 - Set the custom role as the default role for the user. GRANT READ, WRITE ON STAGE existing_stage1 TO ROLE kafka_connector_role_1 - Grant the custom role to an existing user. GRANT OWNERSHIP ON TABLE existing_table1 TO ROLE kafka_connector_role_1 - Only required if the Kafka connector will stage data files in an existing internal stage: (not recommended).

GRANT USAGE ON SCHEMA kafka_schema TO ROLE kafka_connector_role_1 GRANT CREATE TABLE ON SCHEMA kafka_schema TO ROLE kafka_connector_role_1 GRANT CREATE STAGE ON SCHEMA kafka_schema TO ROLE kafka_connector_role_1 GRANT CREATE PIPE ON SCHEMA kafka_schema TO ROLE kafka_connector_role_1 - Only required if the Kafka connector will load data into an existing table. GRANT USAGE ON DATABASE kafka_db TO ROLE kafka_connector_role_1 - Grant privileges on the schema. CREATE ROLE kafka_connector_role_1 - Grant privileges on the database. USE ROLE securityadmin - Create a Snowflake role with the privileges to work with the connector. Use a role that can create and manage roles and privileges. The role should be assigned as the default role for the user. Snowflake recommends that you create a separate user (using CREATE USER) and role (using CREATE ROLE) for each Kafka instance so that the access privileges can be individually revoked if needed. has the OWNERSHIP privilege on the stage). If the connector creates a new stage to temporarily store data files consumed from the Kafka topic, the default role for the user specified in the Kafka configuration file becomes the stage owner (i.e. Only required when using the Kafka connector to stage data files from Kafka to an existing internal stage (not recommended). has the OWNERSHIP privilege on the table). If the connector creates a new target table for records from the Kafka topic, the default role for the user specified in the Kafka configuration file becomes the table owner (i.e. Only required when using the Kafka connector to ingest data into an existing table.

CREATE PIPEĪfter the schema-level objects have been created, the CREATE object privileges can be revoked. Creating and managing Snowflake objects used by the Kafka connector requires a role with the following minimum privileges: