Hybrid batch and stream processing
summary
XComponent Koordinator is a central catalog and REST API that lets business users compose light orchestration scenarios mixing batch jobs and streaming pipelines, claiming no-code integration rather than developer-only code. Implementation uses Kafka for stream links, a polling REST worker API, and a typed catalog; demo runs with a single-node Kafka and four workers downloading URLs into zipped results. Coordinator enforces input/output schemas, starts consumers before producers, supports retries and timeouts, and the live demo partly fails due to Kafka timing.
AI-written summary · about
chapters (10)
- 0:00Start
- 3:15BUT THE TRANSITION IS NOT IMMEDIATE...
- 5:21ORCHESTRATION X CHOREOGRAPHY
- 7:27I OUR TECHNICAL SOLUTION: ILIGHT ORCHESTRATION
- 11:27HIGH LEVEL ARCHITECTURE
- 12:45DEMO SCENARIO
- 16:12INSIDE THE KAFKA WORKER: CATALOG
- 17:09INSIDE THE KAFKA WORKER: EXECUTION
- 18:33DEMO: ON THE BUSINESS SIDE
- 23:47CONCLUSION
related talks
03h 00mStream Processing, Going Beyond Pub/Sub with Kafka Streams and...
45mApplications in the Emerging World of Stream Processing
50mApplication development and data in the emerging world ...
33mKafka Microservices with Kafka plus Akka and Kafka Streams
31mBridge to the Cloud
55mDemystifying Stream Processing with Apache Kafka
40mEvent Streaming Applications with Kafka Streams, Spring Kafka and Actuator
47mFlowable business processing from Kafka events
