Which Snowflake objects are used by the Snowflake Kafka connector?
The Kafka connector creates a named internal stage for each Kafka topic and a pipe for each topic partition to stage and ingest files through Snowpipe. Files that fail to load are moved to the target table’s internal stage. A serverless task, user stage, and storage integration are not connector objects in this loading flow.
Community Discussion