Why Spring Belongs In Your Data Stream (From Edge to Multi Cloud)
summary
Live demo builds an end-to-end pipeline: MQTT sensors -> MiNiFi edge agent -> NiFi -> Kafka -> Flink SQL -> alert topic -> MQTT actuator, all wired with the Spring dashboard showing real-time values. No custom code required to reshape JSON, register schemas, or run windowed averages; Flink runs sliding 15s windows every 5s and triggers alerts when average temperature >30°C. Community Docker compose boots Kafka, Flink, NiFi; Flink sustains thousands/sec, NiFi persists to disk for at-least-once safety and HA via three nodes.
AI-written summary · about
chapters (5)
- 0:00Start
- 4:26FLINK IS A DISTRIBUTED DATA PROCESSING SYSTEM
- 9:08CSP Community Edition
- 10:00Greenhouse demo architecture - Today Demo
- 14:19Greenhouse demo architecture - Original Version
related talks
50mWalking Through Spring Cloud Data Flow
52mCloud-native streaming and event-driven microservices
47mStream All the Things!
01h 06mOrchestrating Data Microservices with Spring Cloud Data Flow - Mark Pollack
40mFlink in Zalando's World of Microservices
44mData Processing With Microservices
26mHow Streaming Helps Your Staging Environment and Sandboxes Stay Up To Date
43mEvent Streams & Data Rapids: Harnessing the Full Power of Messaging Platforms.
