Apache Kafka + Apache Mesos = Highly Scalable Streaming Microservices
summary
A working demo deploys Apache Kafka on DC/OS with 3 brokers and a Kafka Streams microservice that embeds an H2O decision‑tree model to predict flight delays, creating input and output topics and using a Kafka VIP bootstrap URL for a stable endpoint. The service starts with one instance and is scaled from 1 to 5 instances via Marathon/Docker so partitions are rebalanced (round‑robin when messages lack keys); it processes each event exactly once and recovers on failure, though the Mesosphere Kafka client (0.9) requires upgrading for Kafka Streams timestamps.
AI-written summary · about
chapters (8)
- 0:00Introduction and agenda
- 1:23Microservices motivation
- 4:27Apache Kafka ecosystem
- 9:31Kafka Streams introduction
- 18:14Kafka on DC/OS
- 22:48Live demo and scaling
- 31:30Key takeaways
- 36:03Q&A session
related talks
33mKafka Microservices with Kafka plus Akka and Kafka Streams
33mMicroservices, Events, and Breaking the Data Monolith with Kafka
41mReducing Microservice Complexity with Kafka and Reactive Streams
40mDeploying Kafka Streams Applications...
21mHow Apache Kafka® Generates Value In Retail With Confluent
59mBuilding Data Intensive Microservices with Apache Kafka
31mEvent driven communication with Kafka on Kubernetes
48mBuilding a Microservice Application Using Kafka and Django
