I Replaced a Flink Cluster With One Python Process
TL;DR. The canonical streaming-interview feature — "clicks in the last 5 minutes" — over a 3-broker Kafka cluster. I built it on PyFlink first: a JobManager, two TaskManagers, an Apache Beam portabili
seng-wei-chieh.hashnode.dev9 min read