
11/20/2020 · Robin Moffatt
What this post added
This post details building data pipelines by transforming raw CSV data from car park occupancy into a structured format using ksqlDB, applying schemas, setting message keys for partitioning, adding source fields for lineage, deriving and storing timestamps, creating nested location structs, and calculating new fields. The processed data is then streamed to Elasticsearch for analytics and visualization with Kibana.