Courseiva

AI0-001 AI Infrastructure and Technologies Practice Question

A data engineer needs to process streaming clickstream data for real-time feature engineering in an ML pipeline. Which data pipeline technology is BEST suited for this task?

⚠ Common exam trap

CompTIA AI often tests the distinction between data ingestion/messaging systems (Kafka) and batch processing or storage systems, leading candidates to confuse Airflow's orchestration role with actual stream processing capabilities.

Answer choices

Why each option matters

Answer the question above first, then reveal the full breakdown to understand why each option is right or wrong.

Correct answer & explanation

✓

Apache Kafka

Apache Kafka is the best choice because it is a distributed streaming platform designed for high-throughput, fault-tolerant, real-time data ingestion and processing. It can capture clickstream events as they occur and make them immediately available for feature engineering in an ML pipeline, supporting exactly-once semantics and low-latency delivery.

Answer analysis

Option-by-option breakdown

For each option: why learners choose it and why it is or isn't the right answer here.

  • ✗

    Apache Spark in batch mode

    Why it's wrong here

    Spark batch mode processes bounded datasets on a schedule, so clickstream events arriving continuously are only transformed after each job triggers, not per event. Spark Structured Streaming would fit; batch mode suits periodic reprocessing of landed historical data.

  • ✗

    Snowflake

    Why it's wrong here

    Snowflake ingests streaming via Snowpipe but lands data in micro-partitions for SQL analytics; it cannot execute continuous per-event feature computation with sub-second latency. It suits batch or micro-batch warehousing, where near-real-time aggregates over staged data are acceptable.

  • ✓

    Apache Kafka

    Why this is correct

    Kafka is a distributed publish-subscribe log that ingests continuous event streams with low latency and durable ordering, satisfying the real-time feature engineering requirement. Batch stores such as S3 or HDFS cannot process clickstream events as they arrive, so they fail the streaming constraint.

  • ✗

    Apache Airflow

    Why it's wrong here

    Airflow orchestrates scheduled tasks; it triggers jobs at intervals rather than processing each event as it arrives, so feature freshness is bounded by the DAG schedule. It is the right tool for coordinating batch pipelines and dependencies, not continuous stream computation.

About these practice questions

One of 962 original AI0-001 practice questions on Courseiva, each with a full explanation and wrong-answer analysis — not exam dumps or protected exam content. Learn why practice questions differ from exam dumps →

How Courseiva writes practice questions · Editorial policy

JA

Written by Johnson Ajibi, MSc IT Security

Senior Network & Security Engineer · founder of Courseiva

This AI0-001 practice question is part of Courseiva's free CompTIA certification practice question bank. Courseiva provides original exam-style practice questions with explanations, topic-based practice, mock exams, readiness tracking, and study analytics to help learners prepare for the AI0-001 exam.