Deal of The Day! Hurry Up, Grab the Special Discount - Save 25% - Ends In 00:00:00 Coupon code: SAVE25
Welcome to Pass4Success

- Free Preparation Discussions

Databricks Certified Data Engineer Associate Exam - Topic 1 Question 69 Discussion

A data engineering team needs to integrate two data sources into Databricks:Clickstream events: 5,000 events per second from an Apache Kafka topicCustomer master data: Only changed records every four hours from a Snowflake databaseThe solution must process clickstream data with latency under 30 seconds and prevent reprocessing customer master data that has not changed.Which ingestion approach meets these requirements?
A) Use Structured Streaming for Kafka and a Lakeflow Connect managed connector with incremental processing for Snowflake.
B) Use a non-incremental Snowflake connector, fetch all data every four hours, and apply MERGE operations.
C) Use spark.readStream() with Kafka and query Snowflake hourly using a time-based filter.
D) Use Structured Streaming for Kafka and a Lakeflow Connect connector with a full refresh for Snowflake.

Databricks Certified Data Engineer Associate Exam - Topic 1 Question 69 Discussion

Actual exam question for Databricks's Databricks Certified Data Engineer Associate exam
Question #: 69
Topic #: 1
[All Databricks Certified Data Engineer Associate Questions]

A data engineering team needs to integrate two data sources into Databricks:

Clickstream events: 5,000 events per second from an Apache Kafka topic

Customer master data: Only changed records every four hours from a Snowflake database

The solution must process clickstream data with latency under 30 seconds and prevent reprocessing customer master data that has not changed.

Which ingestion approach meets these requirements?

Show Suggested Answer Hide Answer
Suggested Answer: A

Contribute your Thoughts:

0/2000 characters

Currently there are no comments in this discussion, be the first to comment!


Save Cancel