Real-time streaming pipeline with Apache Flink 2.0, Kafka and Iceberg

How I built an end-to-end streaming pipeline on the Olist dataset: CEP anomaly detection, event-time watermarks, Iceberg integration and the integration issues I didn't anticipate.