SnowPro Advanced Data Engineer DEA-C02

SnowPro Advanced Data Engineer DEA-C02 practice questions, page 2 of 3, with answer review and explanations.

Question 6

When loading data using the Snowflake Connector for Kafka, the Kafka log file contained this information: org.apache.kafka.clients.consumer.CommitFailedException: Commit cannot be completed since the group has already rebalanced and assigned the partitions to another member What combination of tasks should be used to address this issue? (Choose two.)

  1. Decrease the number of records loaded with each operation to 50.
  2. Disable automatic offset migration by setting it to = FALSE.
  3. Increase the execution timeout to 900000.
  4. Reduce the session.timeout.ms setting to enable faster rebalancing.
  5. Add more partitions to the Kafka topic to prevent rebalancing.

Question 7

If data was loaded into a table that had no row limitations, which object can be used to troubleshoot the data loading history?

  1. LOAD_HISTORY view
  2. COPY_HISTORY table function
  3. STAGE_DIRECTORY_FILE_REGISTRATION_HISTORY view
  4. SYSTEM$PIPE_STATUS function

Question 8

A Data Engineer is working on a continuous data pipeline which receives data from Amazon Kinesis Data Firehose and loads the data into a staging table which will later be used in the data transformation process. The average file size is 300-500 MB. How can the Engineer ensure that Snowpipe is performant while MINIMIZING costs?

  1. Increase the size of the virtual warehouse used by Snowpipe.
  2. Split the files before loading them and set the SIZE_LIMIT option to 250 MB.
  3. Change the file compression size and increase the frequency of the Snowpipe loads.
  4. Decrease the buffer size to trigger delivery of files sized between 100 to 250 MB in Kinesis Data Firehose.

Question 9

A Data Engineer is implementing a near real-time ingestion pipeline to load data into Snowflake using the Snowflake Kafka connector. There will be three Kafka topics created. Which Snowflake objects are created automatically when the Kafka connector starts? (Choose three.)

  1. Tables
  2. Tasks
  3. Pipes
  4. Internal stages
  5. External stages
  6. Materialized views

Question 10

Which file format option is used to escape the '\' character while unloading data to a stage from a table if the FIELD_DELIMITER = ','?

  1. ESCAPE_UNENCLOSED_FIELD=NONE
  2. ESCAPE_UNENCLOSED_FIELD='\\'
  3. ESCAPE_UNENCLOSED_FIELD='\'
  4. ESCAPE_UNENCLOSED_FIELD=','