
2/4/2026 · Piotr Duda
What this post added
Focal Systems details their implementation of an AI retail operating system using Confluent's managed Kafka and Flink. They describe how they ingest retail data (shelf images, product updates, inventory, sales), process it with computer vision and ML models on GCP, and use Flink SQL to compute real-time metrics and aggregates for shelf availability, out-of-stock events, and planogram compliance. The system outputs operational data to MongoDB and analytical data to Snowflake. The post highlights challenges with high-cardinality data, scalability, and the need for managed solutions, and explains how Confluent's platform addresses these by providing an event-driven streaming backbone and stream processing capabilities.