As part of the Kafka connector workflow, which objects are created for each topic?

• A. One internal stage to temporarily store data files for each topic
• B. One pipe to ingest the data files for each topic partition
• C. One table for each topic
• D. All of the above

Answer: (D)

In Snowflake's Kafka Connector workflow, every topic gets its own set of Snowflake objects to handle ingestion cleanly and in parallel. The internal stage serves as a temporary landing area where data from the topic is written as files. A pipe then defines the loading process that reads those staged files and loads them into the topic’s dedicated table. The table is the persistent destination where all messages from that topic are stored for querying and analysis. Because you need a place to land the data, a way to move it into Snowflake, and a dedicated destination for each topic, all three objects are created for every topic.