In the Kafka Connector workflow, which object is created to ingest data files for each topic partition?

• A. One internal stage
• B. One pipe
• C. One table
• D. One external stage

Answer: (B)

In this workflow, data ingestion is driven by Snowpipe, and the object that handles loading is a pipe. A separate pipe is created for each Kafka topic partition. Each pipe points to the stage where the Kafka Connector writes data files for that partition and automatically loads them into the target Snowflake table as new files appear. This per-partition setup enables parallel ingestion and preserves the partition-level flow of messages, which aligns with how Kafka organizes data. Stages (internal or external) are just storage locations the pipes read from, and the table is the destination, but the actual ingestion mechanism that triggers and manages the loading is the pipe.