Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.
-
Updated
Apr 28, 2026 - Go
Kubernetes operator for managing the lifecycle of Apache Flink and Beam applications.
A tool that help automate deployment to an Apache Flink cluster
Flink Monitoring API Golang Library https://godoc.org/github.com/flink-go/api
Run templatable playbooks of Hadoop/Spark/et al jobs on Amazon EMR
The Golang APIs for Apache Flink K8s Operator APIs (CRDs) and Flink Rest APIs.
A simple service for discovering Flink cluster on Hadoop Yarn
This is a production-grade blueprint for high-scale, event-driven applications. Built on the principles of **Domain-Driven Design (DDD)** and **Event Sourcing**, it provides the underlying "chassis" for rapidly spinning up complex product services—such as high-frequency transactional platforms (Uber) or massive-scale social streams (TikTok).
Flink exceptions alerting made simple (with go!).
Production-grade recommendation system pipeline for 50M DAU commerce services. 4-Plane architecture (Data/Stream/Batch/Control) with 3-Tier serving (CDN → Cache → CPU → GPU). Runs locally with docker-compose, scales to 500K RPS on Kubernetes.
A distributed mock stock trading system demonstrating scalable microservices architecture with real-time market data processing, portfolio management, and order execution
Add a description, image, and links to the flink topic page so that developers can more easily learn about it.
To associate your repository with the flink topic, visit your repo's landing page and select "manage topics."