Your infrastructure team at StreamEdge Corp has configured an Interconnect link between your on-premises network and Google Cloud . You’re designing a high-throughput streaming data pipeline to ingest data from an Apache Kafka cluster hosted on-premises . You want to store the ingested data in BigQuery with minimal latency . What is the most effective and reliable way to implement this solution?