Scenario: Your infrastructure team has set up an interconnect link between Google Cloud and the on-premises network. You are designing a high-throughput streaming pipeline to ingest data from an on-premises Apache Kafka cluster and store it in BigQuery with minimal latency. Question: How should you ingest data from Apache Kafka to BigQuery with minimal latency?