Building a hybrid data pipeline using Kafka and Confluent

array(10) { [0]=> object(stdClass)#5137 (5) { ["video_id"]=> int(9999999) ["related_video_id"]=> string(11) "g6Fmrmh8C20" ["related_video_title"]=> string(96) "Managed Airflow Instance with Google Cloud Composer | Product Spotlight | Google Cloud Platform" ["posted_time"]=> string(21) "3 года назад" ["channelName"]=> string(12) "Sushil Kumar" } [1]=> object(stdClass)#5110 (5) { ["video_id"]=> int(9999999) ["related_video_id"]=> string(11) "PRvUVVCVIUI" ["related_video_title"]=> string(69) "From Kafka to BigQuery – Ofir Sharony, Kafka Summit London 2018" ["posted_time"]=> string(19) "6 лет назад" ["channelName"]=> string(12) "Ofir Sharony" } [2]=> object(stdClass)#5135 (5) { ["video_id"]=> int(9999999) ["related_video_id"]=> string(11) "hbseyn-CfXY" ["related_video_title"]=> string(74) "Лучший Гайд по Kafka для Начинающих За 1 Час" ["posted_time"]=> string(28) "11 месяцев назад" ["channelName"]=> string(14) "Vlad Mishustin" } [3]=> object(stdClass)#5142 (5) { ["video_id"]=> int(9999999) ["related_video_id"]=> string(11) "tIyibb4Dc_M" ["related_video_title"]=> string(101) "Creating a free trial marketing strategy that works - Alan Hwang & Mike Nierengarten | PLGTM 2025" ["posted_time"]=> string(21) "7 дней назад" ["channelName"]=> string(42) "PLGTM - The only event for product-led GTM" } [4]=> object(stdClass)#5121 (5) { ["video_id"]=> int(9999999) ["related_video_id"]=> string(11) "-AZOi3kP9Js" ["related_video_title"]=> string(27) "Про Kafka (основы)" ["posted_time"]=> string(21) "4 года назад" ["channelName"]=> string(41) "Владимир Богдановский" } [5]=> object(stdClass)#5139 (5) { ["video_id"]=> int(9999999) ["related_video_id"]=> string(11) "_mfs4RANcc8" ["related_video_title"]=> string(100) "From ETL to Automation: Leveraging DBT, BigQuery, CI/CD and Airflow - Anima Acharya|GDG Sydney Jun25" ["posted_time"]=> string(25) "2 недели назад" ["channelName"]=> string(10) "GDG Sydney" } [6]=> object(stdClass)#5134 (5) { ["video_id"]=> int(9999999) ["related_video_id"]=> string(11) "blWdjRUPP6E" ["related_video_title"]=> string(72) "Разведчик о том, как использовать людей" ["posted_time"]=> string(25) "3 недели назад" ["channelName"]=> string(18) "Коллектив" } [7]=> object(stdClass)#5144 (5) { ["video_id"]=> int(9999999) ["related_video_id"]=> string(11) "d4cu_rzv4A8" ["related_video_title"]=> string(57) "GCP Cloud Composer Introduction | Airflow managed service" ["posted_time"]=> string(21) "2 года назад" ["channelName"]=> string(26) "Anjan GCP Data Engineering" } [8]=> object(stdClass)#5120 (5) { ["video_id"]=> int(9999999) ["related_video_id"]=> string(11) "8fNnqshJ2Nw" ["related_video_title"]=> string(34) "Protect data with authorized views" ["posted_time"]=> string(21) "4 года назад" ["channelName"]=> string(17) "Google Cloud Tech" } [9]=> object(stdClass)#5138 (5) { ["video_id"]=> int(9999999) ["related_video_id"]=> string(11) "YtbfPlvHcEs" ["related_video_title"]=> string(60) "Data Warehouse Modernization with Confluent and Google Cloud" ["posted_time"]=> string(21) "3 года назад" ["channelName"]=> string(9) "Confluent" } }