Data Wrangling with Apache Kafka and KSQL | Confluent

This post details data wrangling tasks using KSQL, including applying schemas, filtering, masking, restructuring, enriching, and unifying data streams. It demonstrates pulling data from REST sources using Kafka Connect, processing it with KSQL, and streaming it to Google Cloud Storage and BigQuery. The post also covers declaring schemas for JSON data and handling variations in data structures, such as arrays.