DEA-C02 Question #67: Real Exam Question with Answer & Explanation

Question

Which of the following grants are required for the role running the kafka_load_role_1 Snowflake Connector for Kafka, with the intent of loading data to Snowflake? (Choose three.) (Assume this role already exists and has usage access to the schema in kafka_schema database kafka_db, the target for data loading.)

Options

• Agrant create pipe on schema kafka_schema to role kafka_load_role_1;
• Bgrant create stream on schema kafka_schema to role kafka_load_role_1;
• Dgrant create table on schema kafka_schema to role kafka_load_role_1;
• Egrant create task on schema kafka_schema to role kafka_load_role_1;

Explanation

For the Snowflake Connector for Kafka to load data, the role needs CREATE PIPE (A) because the connector relies on Snowpipe to ingest streaming data efficiently into Snowflake, and CREATE TABLE (D) because the connector must be able to create destination tables in the target schema if they don't already exist. Note that the question says "choose three" - the displayed options are missing option C (CREATE STAGE), which is the third required grant; the connector needs to create internal stages as temporary landing zones before data is moved into tables via Snowpipe.

B (CREATE STREAM) is wrong because streams are a Snowflake CDC mechanism for tracking row-level changes, which plays no role in the Kafka ingestion pipeline. E (CREATE TASK) is wrong because tasks are used to schedule SQL statements on a recurring basis - the Kafka connector handles its own scheduling and does not rely on Snowflake Tasks.

Memory tip: Think of the Kafka Connector's three-step loading process - Stage → Pipe → Table - and you immediately know the three grants needed: CREATE STAGE, CREATE PIPE, and CREATE TABLE.

No community discussion yet for this question.